Function handleRequest

packages/experimental/src/EventLogServer.ts:65–132

(request: typeof ProtocolRequest.Type)

    yield* Effect.fork(write(new Hello({ remoteId })))

    function handleRequest(request: typeof ProtocolRequest.Type) {
      switch (request._tag) {
        case "Ping": {
          return write(new Pong({ id: request.id }))
        }
        case "WriteEntries": {
          if (request.encryptedEntries.length === 0) {
            return write(
              new Ack({
                id: request.id,
                sequenceNumbers: []
              })
            )
          }
          return Effect.gen(function*() {
            const entries = request.encryptedEntries.map(({ encryptedEntry, entryId }) =>
              new PersistedEntry({
                entryId,
                iv: request.iv,
                encryptedEntry
              })
            )
            const encrypted = yield* storage.write(request.publicKey, entries)
            latestSequence = encrypted[encrypted.length - 1].sequence
            return yield* write(
              new Ack({
                id: request.id,
                sequenceNumbers: encrypted.map((e) => e.sequence)
              })
            )
          })
        }
        case "RequestChanges": {
          return Effect.gen(function*() {
            const changes = yield* storage.changes(request.publicKey, request.startSequence)
            return yield* changes.takeAll.pipe(
              Effect.flatMap(function([entries]) {
                const latestEntries: Array<EncryptedRemoteEntry> = []
                for (const entry of entries) {
                  if (entry.sequence <= latestSequence) continue
                  latestEntries.push(entry)
                  latestSequence = entry.sequence
                }
                if (latestEntries.length === 0) return Effect.void
                return write(
                  new Changes({
                    publicKey: request.publicKey,
                    entries: Chunk.toReadonlyArray(entries)
                  })
                )
              }),
              Effect.forever
            )
          }).pipe(
            Effect.scoped,
            FiberMap.run(subscriptions, request.publicKey)
          )
        }