icey-yu
|
72102b0378
|
feat: lock in online cache
|
2024-09-09 17:02:03 +08:00 |
|
icey-yu
|
95d2227da2
|
feat: get all online users and init push
|
2024-09-09 16:40:57 +08:00 |
|
icey-yu
|
a141eefc5e
|
feat: batch get user online
|
2024-09-07 18:00:45 +08:00 |
|
icey-yu
|
16fd28f39f
|
feat: init
|
2024-09-07 17:25:47 +08:00 |
|
icey-yu
|
04f56a9c00
|
feat: init
|
2024-09-07 17:13:17 +08:00 |
|
icey-yu
|
35c6dc2706
|
feat: remove port reuse
|
2024-09-07 15:30:49 +08:00 |
|
icey-yu
|
7143444bd2
|
feat: logs
|
2024-09-07 14:37:04 +08:00 |
|
icey-yu
|
7a35975ba1
|
feat: add sleep in push
|
2024-09-06 15:23:33 +08:00 |
|
icey-yu
|
842be3a71d
|
feat: fix err
|
2024-09-06 14:43:00 +08:00 |
|
icey-yu
|
834964a3f2
|
feat: del interface
|
2024-09-06 14:38:25 +08:00 |
|
icey-yu
|
db4e1c1005
|
Merge branch 'fix-err' into fix-err
|
2024-09-06 10:01:06 +08:00 |
|
icey-yu
|
0aed52e7c9
|
feat: print getOnline cost
|
2024-09-06 09:56:57 +08:00 |
|
Monet Lee
|
3eb260fe28
|
Merge branch 'fix-err' of github.com:icey-yu/open-im-server into fix-err
|
2024-09-05 18:56:48 +08:00 |
|
Monet Lee
|
c667795285
|
feat: implement Getbatch in rpcCache.
|
2024-09-05 18:47:54 +08:00 |
|
icey-yu
|
1ce82ab92d
|
feat: change log
|
2024-09-05 18:33:03 +08:00 |
|
icey-yu
|
c8d5cd6eba
|
feat: change 1s
|
2024-09-05 18:31:41 +08:00 |
|
icey-yu
|
09fc762a58
|
feat: sleep
|
2024-09-05 17:58:11 +08:00 |
|
icey-yu
|
f7eb050457
|
feat: with operationID
|
2024-09-05 17:44:58 +08:00 |
|
icey-yu
|
8920b48718
|
feat: push err
|
2024-09-05 17:39:05 +08:00 |
|
icey-yu
|
d9064867d5
|
chore: enable fullUserCache
|
2024-09-05 17:22:05 +08:00 |
|
icey-yu
|
7f8d26c36b
|
feat: cache batch
|
2024-09-05 14:35:40 +08:00 |
|
icey-yu
|
176eb00941
|
feat: add logs
|
2024-09-05 10:25:45 +08:00 |
|
icey-yu
|
5555f31961
|
feat: enable listen TIME_WAIT port
|
2024-09-04 19:23:39 +08:00 |
|
icey-yu
|
076205a290
|
feat: listen config
|
2024-09-04 18:59:18 +08:00 |
|
icey-yu
|
f2c876380a
|
feat: wrap logs
|
2024-09-04 17:40:03 +08:00 |
|
icey-yu
|
8af9dcb99c
|
feat: add rocksTimeout
|
2024-09-04 17:39:49 +08:00 |
|
chao
|
2477a6658c
|
feat: supports getting messages based on session ID and seq (#2582)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* update gomake version
* update gomake version
* fix: seq conversion bug
* fix: redis pipe exec
* fix: ImportFriends
* fix: A large number of logs keysAndValues length is not even
* feat: mark read aggregate write
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* merge
* merge
* read seq is written to mongo
* read seq is written to mongo
* fix: invitation to join group notification
* fix: friend op_user_id
* feat: optimizing asynchronous context
* feat: optimizing memamq size
* feat: add GetSeqMessage
* feat: GroupApplicationAgreeMemberEnterNotification
* feat: GroupApplicationAgreeMemberEnterNotification
* feat: go.mod
* feat: go.mod
* feat: join group notification and get seq
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
|
2024-09-04 03:14:21 +00:00 |
|
icey-yu
|
38a8802107
|
feat: add long time push msg in prometheus (#2584)
* feat: add long time push msg in prometheus
* fix: log print
* fix: go mod
* fix: log msg
* fix: log init
* feat: push msg
* feat: go mod ,remove cgo package
* feat: remove error log
* feat: test dummy push
* feat:redis pool config
* feat: push to kafka log
|
2024-09-03 10:32:40 +00:00 |
|
chao
|
275491a1b5
|
fix: memory queue optimization (#2568)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* update gomake version
* update gomake version
* fix: seq conversion bug
* fix: redis pipe exec
* fix: ImportFriends
* fix: A large number of logs keysAndValues length is not even
* feat: mark read aggregate write
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* merge
* merge
* read seq is written to mongo
* read seq is written to mongo
* fix: invitation to join group notification
* fix: friend op_user_id
* feat: optimizing asynchronous context
* feat: optimizing memamq size
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
|
2024-08-29 07:18:23 +00:00 |
|
chao
|
85614da36f
|
fix: read seq is written to mongo, online status redis cluster is supported (#2558)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* update gomake version
* update gomake version
* fix: seq conversion bug
* fix: redis pipe exec
* fix: ImportFriends
* fix: A large number of logs keysAndValues length is not even
* feat: mark read aggregate write
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* feat: online status supports redis cluster
* merge
* merge
* read seq is written to mongo
* read seq is written to mongo
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
|
2024-08-26 10:45:44 +00:00 |
|
icey-yu
|
86a325f309
|
Fix push (#2559)
* fix:log
* fix: add log
* fix: del return
* fix: push config
* feat: add push err log and extend push wait time
* feat: group config
* feat: add log in write binary msg
* feat: Modify Prometheus data scraping ports and reserve port space.
* feat: change group rpc num
* feat: change log
* fix: remove quotation mark
|
2024-08-26 10:15:05 +00:00 |
|
icey-yu
|
938409b0e4
|
fix: set min seq (#2556)
* fix:log
* fix: set min seq
|
2024-08-26 07:57:57 +00:00 |
|
Monet Lee
|
fa1467878b
|
feat: implement SetGroupInfoEX interface. (#2552)
* refactor: refactor workflows contents.
* add tool workflows.
* update field.
* fix: remove chat error.
* Fix err.
* fix error.
* remove cn comment.
* update workflows files.
* update infra config.
* move workflows.
* feat: update bot.
* fix: solve uncorrect outdated msg get.
* update get docIDs logic.
* update
* update skip logic.
* fix
* update.
* feat: implement `SetGroupInfoEX` interface.
* remove null interface.
* update router.
|
2024-08-26 06:29:10 +00:00 |
|
icey-yu
|
7deb45e35d
|
Groupmsg (#2548)
* feat: add EnableHistoryForNewMembers
* feat: change name
* refactor: move first create conversation
* fix: set min seq
|
2024-08-23 09:34:58 +00:00 |
|
qinguoyi
|
f44a97b8d2
|
fix:mgo delete err (#2496)
|
2024-08-21 07:26:53 +00:00 |
|
qinguoyi
|
97f4b51874
|
fix:get msg error (#2494)
|
2024-08-21 07:25:19 +00:00 |
|
icey-yu
|
0af207b625
|
Fix config (#2541)
* feat: remove double quotation marks
* feat: test
* feat: default close prometheus
|
2024-08-21 07:10:43 +00:00 |
|
Mew151
|
1022b297d4
|
fix 细节 (#2525)
1、统一结构体方法 receiver，都用 pointer
2、使用 errors.Is 来做错误判断
3、修复单词拼写的错误
|
2024-08-21 03:44:00 +00:00 |
|
Monet Lee
|
27024dfb03
|
fix: solve uncorrect outdated msg get. (#2513)
* refactor: refactor workflows contents.
* add tool workflows.
* update field.
* fix: remove chat error.
* Fix err.
* fix error.
* remove cn comment.
* update workflows files.
* update infra config.
* move workflows.
* feat: update bot.
* fix: solve uncorrect outdated msg get.
* update get docIDs logic.
* update
* update skip logic.
* fix
* update.
|
2024-08-14 10:20:42 +00:00 |
|
icey-yu
|
7110183892
|
h (#2501)
|
2024-08-09 09:52:03 +00:00 |
|
icey-yu
|
17816053f3
|
fix: fix-validate message. (#2499)
|
2024-08-09 08:53:58 +00:00 |
|
qinguoyi
|
33aa2070c4
|
fix:update recive name to same (#2493)
|
2024-08-09 02:05:12 +00:00 |
|
icey-yu
|
9b32c630dc
|
fix: import del cache (#2492)
|
2024-08-08 07:20:01 +00:00 |
|
chao
|
84049a1f55
|
fix: the local cache obtained can be modified (#2473)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* mage
* optimization version log
* optimization version log
* sync
* sync
* sync
* group sync
* sync option
* sync option
* refactor: replace `friend` package with `realtion`.
* refactor: update lastest commit to relation.
* sync option
* sync option
* sync option
* sync
* sync
* go.mod
* seq
* update: go mod
* refactor: change incremental to full
* feat: get full friend user ids
* feat: api and config
* seq
* group version
* merge
* seq
* seq
* seq
* fix: sort by id avoid unstable sort friends.
* group
* group
* group
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* user version
* seq
* seq
* seq user
* user online
* implement minio expire delete.
* user online
* config
* fix
* fix
* implement minio expire delete logic.
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* feat: implement scheduled delete outdated object in minio.
* update gomake version
* update gomake version
* implement FindExpires pagination.
* remove unnesseary incr.
* fix uncorrect args call.
* online push
* online push
* online push
* resolving conflicts
* resolving conflicts
* test
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* rpc prommetrics
* rpc prommetrics
* online status
* online status
* online status
* online status
* sub
* conversation version incremental
* merge seq
* merge online
* merge online
* merge online
* merge seq
* GetOwnerConversation
* fix: change incremental syncer router name.
* rockscache batch get
* rockscache seq batch get
* fix: GetMsgDocModelByIndex bug
* update go.mod
* update go.mod
* merge
* feat: prometheus
* feat: prometheus
* group member sort
* sub
* sub
* fix: seq conversion bug
* fix: redis pipe exec
* sort version
* sort version
* sort version
* remove old version online subscription
* remove old version online subscription
* version log index
* version log index
* batch push
* batch push
* seq void filling
* fix: batchGetMaxSeq
* fix: batchGetMaxSeq
* cache db error log
* 111
* fix bug
* fix: ImportFriends
* add online cache
* add some logs
* add some logs
* fix: onlineUserIDs
* add logs
* test
* test
* test
* test
* add log
* feat: solve the problem that modifying the cached data affects other
* feat: solve the problem that modifying the cached data affects other
* feat: search messages to filter out notifications
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
Co-authored-by: Monet Lee <monet_lee@163.com>
Co-authored-by: OpenIM-Gordon <46924906+FGadvancer@users.noreply.github.com>
Co-authored-by: icey-yu <1186114839@qq.com>
|
2024-08-02 08:58:04 +00:00 |
|
Monet Lee
|
51e170ade1
|
feat: implement scheduled destruct msgs feature in cron task. (#2466)
* update protocol in go mod.
* add debug log in writePongMsg.
* update log level.
* add Warn log in writePongMsg.
* add debug log.
* feat: update webhookBeforeMemberJoinGroup to batch method.
* feat: update version field implement.
* update webhook implement contents.
* update method field and contents.
* update callbackCommand field.
* fix: add correct fields.
* update struct tags.
* refactor: rename friend module to relation.
* feat: implement scheduled destruct msgs feature in cron task.
* update log contents.
* update func name and comments.
* update waitgroup to errgroup.
* update errgroup wait.
* remove unnecessary contents.
* update clearMsg logic.
|
2024-08-01 08:12:41 +00:00 |
|
Monet Lee
|
5dac91569d
|
refactor: rename friend module to relation. (#2463)
* update protocol in go mod.
* add debug log in writePongMsg.
* update log level.
* add Warn log in writePongMsg.
* add debug log.
* feat: update webhookBeforeMemberJoinGroup to batch method.
* feat: update version field implement.
* update webhook implement contents.
* update method field and contents.
* update callbackCommand field.
* fix: add correct fields.
* update struct tags.
* refactor: rename friend module to relation.
|
2024-07-31 10:12:19 +00:00 |
|
chao
|
9cfbc3aaff
|
fix: return value (#2462)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* mage
* optimization version log
* optimization version log
* sync
* sync
* sync
* group sync
* sync option
* sync option
* refactor: replace `friend` package with `realtion`.
* refactor: update lastest commit to relation.
* sync option
* sync option
* sync option
* sync
* sync
* go.mod
* seq
* update: go mod
* refactor: change incremental to full
* feat: get full friend user ids
* feat: api and config
* seq
* group version
* merge
* seq
* seq
* seq
* fix: sort by id avoid unstable sort friends.
* group
* group
* group
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* user version
* seq
* seq
* seq user
* user online
* implement minio expire delete.
* user online
* config
* fix
* fix
* implement minio expire delete logic.
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* feat: implement scheduled delete outdated object in minio.
* update gomake version
* update gomake version
* implement FindExpires pagination.
* remove unnesseary incr.
* fix uncorrect args call.
* online push
* online push
* online push
* resolving conflicts
* resolving conflicts
* test
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* rpc prommetrics
* rpc prommetrics
* online status
* online status
* online status
* online status
* sub
* conversation version incremental
* merge seq
* merge online
* merge online
* merge online
* merge seq
* GetOwnerConversation
* fix: change incremental syncer router name.
* rockscache batch get
* rockscache seq batch get
* fix: GetMsgDocModelByIndex bug
* update go.mod
* update go.mod
* merge
* feat: prometheus
* feat: prometheus
* group member sort
* sub
* sub
* fix: seq conversion bug
* fix: redis pipe exec
* sort version
* sort version
* sort version
* remove old version online subscription
* remove old version online subscription
* version log index
* version log index
* batch push
* batch push
* seq void filling
* fix: batchGetMaxSeq
* fix: batchGetMaxSeq
* cache db error log
* 111
* fix bug
* fix: ImportFriends
* add online cache
* add some logs
* add some logs
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
Co-authored-by: Monet Lee <monet_lee@163.com>
Co-authored-by: OpenIM-Gordon <46924906+FGadvancer@users.noreply.github.com>
Co-authored-by: icey-yu <1186114839@qq.com>
|
2024-07-31 06:21:19 +00:00 |
|
chao
|
d2b02dbabe
|
feat: add some logs (#2461)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* new mongo
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* friend incr sync
* mage
* optimization version log
* optimization version log
* sync
* sync
* sync
* group sync
* sync option
* sync option
* refactor: replace `friend` package with `realtion`.
* refactor: update lastest commit to relation.
* sync option
* sync option
* sync option
* sync
* sync
* go.mod
* seq
* update: go mod
* refactor: change incremental to full
* feat: get full friend user ids
* feat: api and config
* seq
* group version
* merge
* seq
* seq
* seq
* fix: sort by id avoid unstable sort friends.
* group
* group
* group
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* fix: sort by id avoid unstable sort friends.
* user version
* seq
* seq
* seq user
* user online
* implement minio expire delete.
* user online
* config
* fix
* fix
* implement minio expire delete logic.
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* online cache
* feat: implement scheduled delete outdated object in minio.
* update gomake version
* update gomake version
* implement FindExpires pagination.
* remove unnesseary incr.
* fix uncorrect args call.
* online push
* online push
* online push
* resolving conflicts
* resolving conflicts
* test
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* api prommetrics
* rpc prommetrics
* rpc prommetrics
* online status
* online status
* online status
* online status
* sub
* conversation version incremental
* merge seq
* merge online
* merge online
* merge online
* merge seq
* GetOwnerConversation
* fix: change incremental syncer router name.
* rockscache batch get
* rockscache seq batch get
* fix: GetMsgDocModelByIndex bug
* update go.mod
* update go.mod
* merge
* feat: prometheus
* feat: prometheus
* group member sort
* sub
* sub
* fix: seq conversion bug
* fix: redis pipe exec
* sort version
* sort version
* sort version
* remove old version online subscription
* remove old version online subscription
* version log index
* version log index
* batch push
* batch push
* seq void filling
* fix: batchGetMaxSeq
* fix: batchGetMaxSeq
* cache db error log
* 111
* fix bug
* fix: ImportFriends
* add online cache
* add some logs
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
Co-authored-by: Monet Lee <monet_lee@163.com>
Co-authored-by: OpenIM-Gordon <46924906+FGadvancer@users.noreply.github.com>
Co-authored-by: icey-yu <1186114839@qq.com>
|
2024-07-31 02:50:55 +00:00 |
|
Monet Lee
|
fb689618d8
|
feat: update webhookBeforeMemberJoinGroup to batch method. (#2459)
* update protocol in go mod.
* add debug log in writePongMsg.
* update log level.
* add Warn log in writePongMsg.
* add debug log.
* feat: update webhookBeforeMemberJoinGroup to batch method.
* feat: update version field implement.
* update webhook implement contents.
* update method field and contents.
* update callbackCommand field.
* fix: add correct fields.
* update struct tags.
|
2024-07-30 10:09:52 +00:00 |
|
chao
|
ed0ab58a9e
|
fix ImportFriends (#2458)
* fix: GroupApplicationAcceptedNotification
* fix: GroupApplicationAcceptedNotification
* fix: NotificationUserInfoUpdate
* cicd: robot automated Change
* fix: component
* fix: getConversationInfo
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* feat: cron task
* fix: minio config url recognition error
* update gomake version
* update gomake version
* fix: seq conversion bug
* fix: redis pipe exec
* fix: ImportFriends
---------
Co-authored-by: withchao <withchao@users.noreply.github.com>
|
2024-07-29 08:53:26 +00:00 |
|