"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.GroupCipher = void 0;var _crypto = require("libsignal/src/crypto.js");
var _senderKeyMessage = require("./sender-key-message.js");
var _senderKeyName = require("./sender-key-name.js");
var _senderKeyRecord = require("./sender-key-record.js");
var _senderKeyState = require("./sender-key-state.js");
class GroupCipher {
  constructor(senderKeyStore, senderKeyName) {
    this.senderKeyStore = senderKeyStore;
    this.senderKeyName = senderKeyName;
  }
  async encrypt(paddedPlaintext) {
    const record = await this.senderKeyStore.loadSenderKey(this.senderKeyName);
    if (!record) {
      throw new Error('No SenderKeyRecord found for encryption');
    }
    const senderKeyState = record.getSenderKeyState();
    if (!senderKeyState) {
      throw new Error('No session to encrypt message');
    }
    const iteration = senderKeyState.getSenderChainKey().getIteration();
    const senderKey = this.getSenderKey(senderKeyState, iteration === 0 ? 0 : iteration + 1);
    const ciphertext = await this.getCipherText(senderKey.getIv(), senderKey.getCipherKey(), paddedPlaintext);
    const senderKeyMessage = new _senderKeyMessage.SenderKeyMessage(senderKeyState.getKeyId(), senderKey.getIteration(), ciphertext, senderKeyState.getSigningKeyPrivate());
    await this.senderKeyStore.storeSenderKey(this.senderKeyName, record);
    return senderKeyMessage.serialize();
  }
  async decrypt(senderKeyMessageBytes) {
    const record = await this.senderKeyStore.loadSenderKey(this.senderKeyName);
    if (!record) {
      throw new Error('No SenderKeyRecord found for decryption');
    }
    const senderKeyMessage = new _senderKeyMessage.SenderKeyMessage(null, null, null, null, senderKeyMessageBytes);
    const senderKeyState = record.getSenderKeyState(senderKeyMessage.getKeyId());
    if (!senderKeyState) {
      throw new Error('No session found to decrypt message');
    }
    senderKeyMessage.verifySignature(senderKeyState.getSigningKeyPublic());
    const senderKey = this.getSenderKey(senderKeyState, senderKeyMessage.getIteration());
    const plaintext = await this.getPlainText(senderKey.getIv(), senderKey.getCipherKey(), senderKeyMessage.getCipherText());
    await this.senderKeyStore.storeSenderKey(this.senderKeyName, record);
    return plaintext;
  }
  getSenderKey(senderKeyState, iteration) {
    let senderChainKey = senderKeyState.getSenderChainKey();
    if (senderChainKey.getIteration() > iteration) {
      if (senderKeyState.hasSenderMessageKey(iteration)) {
        const messageKey = senderKeyState.removeSenderMessageKey(iteration);
        if (!messageKey) {
          throw new Error('No sender message key found for iteration');
        }
        return messageKey;
      }
      throw new Error(`Received message with old counter: ${senderChainKey.getIteration()}, ${iteration}`);
    }
    if (iteration - senderChainKey.getIteration() > 2000) {
      throw new Error('Over 2000 messages into the future!');
    }
    while (senderChainKey.getIteration() < iteration) {
      senderKeyState.addSenderMessageKey(senderChainKey.getSenderMessageKey());
      senderChainKey = senderChainKey.getNext();
    }
    senderKeyState.setSenderChainKey(senderChainKey.getNext());
    return senderChainKey.getSenderMessageKey();
  }
  async getPlainText(iv, key, ciphertext) {
    try {
      return (0, _crypto.decrypt)(key, ciphertext, iv);
    }
    catch (e) {
      throw new Error('InvalidMessageException');
    }
  }
  async getCipherText(iv, key, plaintext) {
    try {
      return (0, _crypto.encrypt)(key, plaintext, iv);
    }
    catch (e) {
      throw new Error('InvalidMessageException');
    }
  }
}exports.GroupCipher = GroupCipher; /* v9-3df064a0f8158e18 */