utils.ts

import {
  Address,
  BigInt,
  ByteArray,
  Bytes,
  crypto,
  DataSourceTemplate,
  ethereum,
  log,
  store,
  Value,
} from '@graphprotocol/graph-ts';
import {
  BlacklistedDAO,
  ContractInfo,
  ControllerScheme,
  Debug,
  TemplateInfo,
} from './types/schema';

export function concat(a: ByteArray, b: ByteArray): ByteArray {
  let out = new Uint8Array(a.length + b.length);
  for (let i = 0; i < a.length; i++) {
    out[i] = a[i];
  }
  for (let j = 0; j < b.length; j++) {
    out[a.length + j] = b[j];
  }
  return out as ByteArray;
}

export const CLOSING_AT_TIME_DECREASE_GSMC = 32000000;
export const CLOSING_AT_TIME_INCREASE = 2147483647;

export function eventId(event: ethereum.Event): string {
  return crypto
    .keccak256(
      concat(event.transaction.hash, event.transactionLogIndex as ByteArray),
    )
    .toHex();
}

export function hexToAddress(hex: string): Address {
  return Address.fromString(hex.substr(2));
}

/**
 * WORKAROUND: there's no `console.log` functionality in mapping.
 * so we use `debug(..)` which writes a `Debug` entity to the store so you can see them in graphiql.
 */
let debugId = 0;
export function debug(msg: string): void {

  let id = BigInt.fromI32(debugId).toHex();
  let ent = new Debug(id);
  ent.set('message', Value.fromString(msg));
  store.set('Debug', id, ent);
  debugId++;
}

export function equalsBytes(a: Bytes, b: Bytes): boolean {
  if (a.length !== b.length) {
    return false;
  }
  for (let i = 0; i < a.length; i++) {
    if (a[i] !== b[i]) {
      return false;
    }
  }
  return true;
}

export function equalStrings(a: string, b: string): boolean {
  if (a.length !== b.length) {
    return false;
  }
  for (let i = 0; i < a.length; i++) {
    if (a[i].charCodeAt(0) !== b[i].charCodeAt(0)) {
      return false;
    }
  }
  return true;
}

export function setContractInfo(address: string, name: string, alias: string, version: string): void {
    let contractInfo = ContractInfo.load(address);
    if (contractInfo == null) {
        contractInfo = new ContractInfo(address);
        contractInfo.address = Address.fromString(address);
        contractInfo.name =  name;
        contractInfo.alias =  alias;
        contractInfo.version = version;
        contractInfo.save();
    }
}

export function setTemplateInfo(name: string, version: string, templateName: string): void {
  let id = name.concat(version);
  let templateInfo = TemplateInfo.load(id);
  if (templateInfo == null) {
    templateInfo = new TemplateInfo(id);
    templateInfo.templateName = templateName;
    templateInfo.save();
  }
}

export function fetchTemplateName(name: string, version: string): string | null {
  let id = name.concat(version);
  let templateInfo = TemplateInfo.load(id);
  if (templateInfo == null) {
    return null;
  } else {
    return templateInfo.templateName;
  }
}

export function createTemplate(templateName: string, address: Address): void {
  DataSourceTemplate.create(templateName, [address.toHex()]);
}

export function setBlacklistedDAO(address: string): void {
  let blacklistedDAO = BlacklistedDAO.load(address);
  if (blacklistedDAO == null) {
    blacklistedDAO = new BlacklistedDAO(address);
    blacklistedDAO.save();
  }
}

export function fixJsonQuotes(target: string): string {
     let targetIndex = 0;
     let result = '';
     for (targetIndex = 0; targetIndex < target.length; targetIndex++) {
       if (target[targetIndex] === '"') {
         result += '\\"';
       } else {
         result += target[targetIndex];
       }
     }
     return result;
}

export function setSchemeError(schemeId: string, errorCode: BigInt, errorMsg: string): void {
  let controllerScheme = ControllerScheme.load(schemeId);
  if (controllerScheme != null) {
    controllerScheme.error = errorCode;
    controllerScheme.save();
  }
  log.info(errorMsg, []);
}