databag/app/sdk/src/content.ts

import { EventEmitter } from 'eventemitter3';
import type { Content } from './api';
import type { Channel } from './types';
import { ContactModule } from './contact';
import { StreamModule } from './stream';
import { Logging } from './logging';
import { Crypto } from './crypto';

export class ContentModule implements Content {
  private crypto: Crypto | null;
  private log: Logging;
  private emitter: EventEmitter;
  private contact: ContactModule;
  private stream: StreamModule;
  private streamLoaded: boolean;
  private contactLoaded: boolean;

  constructor(log: Logging, crypto: Crypto | null, contact: ContactModule, stream: StreamModule) {
    this.contact = contact;
    this.stream = stream;
    this.log = log;
    this.crypto = crypto;
    this.emitter = new EventEmitter();
    this.streamLoaded = false;
    this.contactLoaded = false;

    this.stream.addLoadedListener((loaded: boolean) => {
      this.streamLoaded = loaded;
      this.emitLoaded();
    });

    this.contact.addLoadedListener((loaded: boolean) => {
      this.contactLoaded = loaded;
      this.emitLoaded();
    });
  }

  public async addChannel(sealed: boolean, type: string, subject: any, cardIds: string[]): Promise<string> {
    if (sealed) {
      if (!this.crypto) {
        throw new Error('crypto not set');
      }
      const { aesKeyHex } = await this.crypto.aesKey();
      const seals = [];
      for (let cardId of cardIds) {
        const seal = await this.contact.getSeal(cardId, aesKeyHex);
        seals.push(seal);
      }
      return await this.stream.addSealedChannel(type, subject, cardIds, aesKeyHex, seals);
    } else {
      return await this.stream.addUnsealedChannel(type, subject, cardIds);
    }
  }

  public async removeChannel(channelId: string): Promise<void> {
    return await this.stream.removeChannel(channelId);
  }

  public async setChannelSubject(channelId: string, type: string, subject: any): Promise<void> {
    return await this.stream.setChannelSubject(channelId, type, subject);
  }

  public async setChannelCard(channelId: string, cardId: string): Promise<void> {
    const getSeal = async (aesKey: string) => {
      return await this.contact.getSeal(cardId, aesKey);
    }
    return await this.stream.setChannelCard(channelId, cardId, getSeal);
  }

  public async clearChannelCard(channelId: string, cardId: string): Promise<void> {
    return await this.stream.clearChannelCard(channelId, cardId);
  }

  public async leaveChannel(cardId: string, channelId: string): Promise<void> {
    return await this.contact.leaveChannel(cardId, channelId);
  }

  public async getChannelNotifications(cardId: string | null, channelId: string): Promise<boolean> {
    if (cardId) {
      return await this.contact.getChannelNotifications(cardId, channelId);
    }
    return await this.stream.getChannelNotifications(channelId);
  }

  public async setChannelNotifications(cardId: string | null, channelId: string, enabled: boolean): Promise<void> {
    if (cardId) {
      return await this.contact.setChannelNotifications(cardId, channelId, enabled);
    }
    return await this.stream.setChannelNotifications(channelId, enabled);
  }

  public async setUnreadChannel(cardId: string | null, channelId: string, unread: boolean): Promise<void> {
    if (cardId) {
      return await this.contact.setUnreadChannel(cardId, channelId, unread);
    }
    return await this.stream.setUnreadChannel(channelId, unread);
  }

  public async flagChannel(cardId: string | null, channelId: string): Promise<void> {
    if (cardId) {
      return await this.contact.flagChannel(cardId, channelId);
    }
    return await this.stream.flagChannel(channelId);
  }

  public async setBlockedChannel(cardId: string | null, channelId: string, blocked: boolean): Promise<void> {
    if (cardId) {
      return await this.contact.setBlockedChannel(cardId, channelId, blocked);
    }
    return await this.stream.setBlockedChannel(channelId, blocked);
  }

  public async getBlockedChannels(): Promise<Channel[]> {
    const channels = await this.stream.getBlockedChannels();
    const cardChannels = await this.contact.getBlockedChannels();
    return channels.concat(cardChannels);
  }

  public async clearBlockedChannelTopic(cardId: string | null, channelId: string, topicId: string): Promise<void> {
    if (cardId) {
      return await this.contact.clearBlockedChannelTopic(cardId, channelId, topicId);
    }
    return await this.stream.clearBlockedChannelTopic(channelId, topicId);
  }

  public addChannelListener(ev: (arg: { channels: Channel[]; cardId: string | null }) => void): void {
    this.stream.addChannelListener(ev);
    this.contact.addChannelListener(ev);
  }

  public removeChannelListener(ev: (arg: { channels: Channel[]; cardId: string | null }) => void): void {
    this.stream.removeChannelListener(ev);
    this.contact.removeChannelListener(ev);
  }

  public addLoadedListener(ev: (loaded: boolean) => void): void {
    this.emitter.on('loaded', ev);
    ev(this.streamLoaded && this.contactLoaded); 
  }   
      
  public removeLoadedListener(ev: (loaded: boolean) => void): void {
    this.emitter.off('loaded', ev);
  }     
        
  private emitLoaded() {
    this.emitter.emit('loaded', this.streamLoaded && this.contactLoaded);
  }    
}