commons.js 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. /**
  2. * 此文件内容为常用的系统枚举及变量。
  3. */
  4. /**
  5. * 系统部署时的配置文件。
  6. *
  7. * @type {string}
  8. */
  9. "use strict";
  10. let configFile = "config.";
  11. if (process.env.IM_PROFILE === "prod") {
  12. configFile += "prod";
  13. } else if (process.env.IM_PROFILE === "test") {
  14. configFile += "test";
  15. } else {
  16. configFile += "dev";
  17. }
  18. exports.CONFIG_FILE = configFile;
  19. /**
  20. * 会话类型
  21. */
  22. const SESSION_TYPES = {
  23. SYSTEM: 0, // 系统会话
  24. MUC: 1, // MUC会话
  25. P2P: 2, // P2P
  26. GROUP: 3, // 固定组
  27. DISCUSSION: 4 // 临时讨论组
  28. };
  29. exports.SESSION_TYPES = SESSION_TYPES;
  30. /**
  31. * 会话状态
  32. */
  33. const TOPIC_STATUS = {
  34. NEW: 0, // 新建
  35. PROCEEDINGS: 1, // 进行中
  36. FINISHED: 10 // 结束
  37. };
  38. exports.TOPIC_STATUS = TOPIC_STATUS;
  39. /**
  40. * 会话参与者角色
  41. */
  42. const PARTICIPANT_ROLES = {
  43. HOST: 0,
  44. REGULAR: 1,
  45. BYSTANDER: 10
  46. };
  47. exports.PARTICIPANT_ROLES = PARTICIPANT_ROLES;
  48. /**
  49. * 消息内容类型。
  50. */
  51. exports.CONTENT_TYPE = {
  52. PlainText: 1, // 信息
  53. Image: 2, // 图片信息
  54. Audio: 3, // 语音信息
  55. Article: 4, // 文章信息
  56. GoTo: 5, // 跳转信息
  57. TopicBegin: 6, // 议题开始
  58. TopicEnd: 7 // 议题结束
  59. };
  60. /**
  61. * 客户端平台。
  62. */
  63. exports.PLATFORM = {
  64. iOS: 0,
  65. Android: 1,
  66. Wechat: 10
  67. };
  68. /**
  69. * 组类型。
  70. */
  71. exports.GROUP_TYPE = {
  72. AdminTeam: 1,
  73. DiscussionGroup: 2
  74. };
  75. /**
  76. * 模型事件。
  77. *
  78. * @type {{Error: string, DataNotFound: string, OK: string}}
  79. */
  80. exports.MODEL_EVENTS = {
  81. Error: "error", // 数据库访问出错
  82. DataNotFound: "no_data", // 找不到指定的数据
  83. OK: "ok", // 操作结束或有数据返回
  84. Exists: "exists" // 数据已存在
  85. };
  86. /**
  87. * 整型最大值。
  88. */
  89. exports.MAX_INT = 9007199254740992;
  90. /**
  91. * 置顶会话基础分值,以此为下限向上递增。
  92. */
  93. exports.STICKY_SESSION_BASE_SCORE = 9000000000000;
  94. /**
  95. * 默认分页大小。
  96. */
  97. exports.DEFAULT_PAGE_SIZE = 100;
  98. /**
  99. * Redis Key列表与占位符。
  100. */
  101. const REDIS_KEY_REPLACER = "{id}";
  102. exports.REDIS_KEY_REPLACER = REDIS_KEY_REPLACER;
  103. exports.SESSION_USER_STATUS = {
  104. ONLINE: 0,
  105. OTHER: 1
  106. };
  107. exports.REDIS_KEYS = {
  108. Users: "users:",
  109. User: "users:" + REDIS_KEY_REPLACER,
  110. UserAppStatus: "users:" + REDIS_KEY_REPLACER + ":app_status",
  111. UserWechatStatus: "users:" + REDIS_KEY_REPLACER + ":wechat_status",
  112. UserSessions: "users:" + REDIS_KEY_REPLACER + ":sessions",
  113. Sessions: "sessions:",
  114. Session: "sessions:" + REDIS_KEY_REPLACER,
  115. SessionParticipants: "participants:" + REDIS_KEY_REPLACER,
  116. SessionParticipantsRole: "participants:" + REDIS_KEY_REPLACER + ":role",
  117. Topics: "sessions:" + REDIS_KEY_REPLACER + ":topics",
  118. Topic: "topics:" + REDIS_KEY_REPLACER,
  119. Messages: "sessions:" + REDIS_KEY_REPLACER + ":messages",
  120. MessagesByTimestamp: "sessions:" + REDIS_KEY_REPLACER + ":messages_by_timestamp"
  121. };
  122. const DB_TABLES = {
  123. P2pMessages: "p2p_messages",
  124. MucMessages: "muc_messages",
  125. GroupMessages: "group_messages",
  126. DiscussionMessages: "discussion_messages",
  127. SystemMessages: "system_messages",
  128. Participants: "participants",
  129. Sessions: "sessions",
  130. Topics: "topics",
  131. StickySessions: "sticky_sessions",
  132. sessionTypeToTableName: function (sessionType) {
  133. if (sessionType == SESSION_TYPES.SYSTEM)
  134. return DB_TABLES.SystemMessages;
  135. else if (sessionType == SESSION_TYPES.MUC)
  136. return DB_TABLES.MucMessages;
  137. else if (sessionType == SESSION_TYPES.P2P)
  138. return DB_TABLES.P2pMessages;
  139. else if (sessionType == SESSION_TYPES.GROUP)
  140. return DB_TABLES.GroupMessages;
  141. else if (sessionType == SESSION_TYPES.DISCUSSION)
  142. return DB_TABLES.DiscussionMessages;
  143. else throw {message: "Unknown session type"};
  144. }
  145. };
  146. exports.DB_TABLES = DB_TABLES;