feat(zulip): add internal api

adapters/zulip/src/bot.ts

@@ -1,9 +1,10 @@
 import { Bot, Context, Logger, Quester, Schema, Universal } from '@satorijs/satori'
 import { HttpPolling } from './polling'
-import { Internal } from './internal'
+import { Internal } from './types'
 import { ZulipMessageEncoder } from './message'
 // @ts-ignore
 import { version } from '../package.json'
+import { decodeGuild } from './utils'
 
 export class ZulipBot extends Bot<ZulipBot.Config> {
   static MessageEncoder = ZulipMessageEncoder
@@ -33,6 +34,29 @@ export class ZulipBot extends Bot<ZulipBot.Config> {
     this.username = full_name
     this.avatar = avatar_url
   }
+
+  async getUser(userId: string, guildId?: string) {
+    const { user } = await this.internal.getUser(userId)
+    return {
+      userId,
+      username: user?.full_name,
+    }
+  }
+
+  async getGuildList() {
+    const { streams } = await this.internal.getStreams()
+    return streams.map(decodeGuild)
+  }
+
+  async getGuild(guildId: string) {
+    const { stream } = await this.internal.getStreamById(guildId)
+    return decodeGuild(stream)
+  }
+
+  async getChannelList(guildId: string) {
+    const { topics } = await this.internal.getStreamTopics(guildId)
+    return topics.map(({ name }) => ({ channelId: name }))
+  }
 }
 
 export namespace ZulipBot {

adapters/zulip/src/index.ts

@@ -3,5 +3,6 @@ import { ZulipBot } from './bot'
 export * from './bot'
 export * from './utils'
 export * from './polling'
+export * from './types'
 
 export default ZulipBot

adapters/zulip/src/message.ts

@@ -24,7 +24,7 @@ export class ZulipMessageEncoder extends MessageEncoder<ZulipBot> {
     form.append('content', this.buffer)
     if (!this.session.isDirect) form.append('topic', this.session.channelId)
 
-    await this.bot.http.post('/api/v1/messages', form, {
+    await this.bot.http.post('/messages', form, {
       headers: form.getHeaders(),
     })
   }

adapters/zulip/src/polling.ts

@@ -5,14 +5,16 @@ import { decodeMessage } from './utils'
 export class HttpPolling extends Adapter.Client<ZulipBot> {
   async start(bot: ZulipBot) {
     await bot.initliaze()
-    const r = await bot.internal.register()
+    const r = await bot.internal.registerQueue({
+      event_types: `["message"]`,
+    })
     let last = -1
     const polling = async () => {
       if (bot.status === 'disconnect') {
         return bot.offline()
       }
       try {
-        const updates = await bot.internal.events({
+        const updates = await bot.internal.getEvents({
           queue_id: r.queue_id,
           last_event_id: last,
         })