/*
 * Copyright (C) 2022 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import { ColorUtils } from '../../component/trace/base/ColorUtils.js';
import {
  BaseStruct,
  dataFilterHandler,
  drawFlagLine,
  drawLines,
  drawLoading,
  drawSelection,
  drawWakeUp,
  drawWakeUpList,
  Render,
  RequestMessage,
} from './ProcedureWorkerCommon.js';
import { TraceRow } from '../../component/trace/base/TraceRow.js';
import { SpSystemTrace } from '../../component/SpSystemTrace.js';

export class EmptyRender extends Render {
  renderMainThread(req: any, row: TraceRow<any>) {
    req.context.beginPath();
    req.context.closePath();
  }
  render(cpuReq: RequestMessage, list: Array<any>, filter: Array<any>) {
    if (cpuReq.canvas) {
      cpuReq.context.clearRect(0, 0, cpuReq.frame.width, cpuReq.frame.height);
      cpuReq.context.beginPath();
      drawLines(cpuReq.context, cpuReq.xs, cpuReq.frame.height, cpuReq.lineColor);
      drawSelection(cpuReq.context, cpuReq.params);
      cpuReq.context.closePath();
      drawFlagLine(
        cpuReq.context,
        cpuReq.flagMoveInfo,
        cpuReq.flagSelectedInfo,
        cpuReq.startNS,
        cpuReq.endNS,
        cpuReq.totalNS,
        cpuReq.frame,
        cpuReq.slicesTime
      );
    }
    // @ts-ignore
    self.postMessage({
      id: cpuReq.id,
      type: cpuReq.type,
      results: cpuReq.canvas ? undefined : filter,
      hover: null,
    });
  }
}

export class CpuRender {
  renderMainThread(
    req: {
      context: CanvasRenderingContext2D;
      useCache: boolean;
      type: string;
      translateY: number;
    },
    row: TraceRow<CpuStruct>
  ) {
    let cpuList = row.dataList;
    let cpuFilter = row.dataListCache;
    dataFilterHandler(cpuList, cpuFilter, {
      startKey: 'startTime',
      durKey: 'dur',
      startNS: TraceRow.range?.startNS ?? 0,
      endNS: TraceRow.range?.endNS ?? 0,
      totalNS: TraceRow.range?.totalNS ?? 0,
      frame: row.frame,
      paddingTop: 5,
      useCache: req.useCache || !(TraceRow.range?.refresh ?? false),
    });
    req.context.beginPath();
    req.context.font = '11px sans-serif';
    cpuFilter.forEach((re) => {
      re.translateY = req.translateY;
      CpuStruct.draw(req.context, re, req.translateY);
    });
    req.context.closePath();
    let currentCpu = parseInt(req.type!.replace('cpu-data-', ''));
    drawWakeUp(
      req.context,
      CpuStruct.wakeupBean,
      TraceRow.range!.startNS,
      TraceRow.range!.endNS,
      TraceRow.range!.totalNS,
      row.frame,
      req.type == `cpu-data-${CpuStruct.selectCpuStruct?.cpu || 0}` ? CpuStruct.selectCpuStruct : undefined,
      currentCpu,
      true
    );
    for (let i = 0; i < SpSystemTrace.wakeupList.length; i++) {
      if (i + 1 == SpSystemTrace.wakeupList.length) {
        return;
      }
      drawWakeUpList(
        req.context,
        SpSystemTrace.wakeupList[i + 1],
        TraceRow.range!.startNS,
        TraceRow.range!.endNS,
        TraceRow.range!.totalNS,
        row.frame,
        req.type == `cpu-data-${SpSystemTrace.wakeupList[i]?.cpu || 0}`
          ? SpSystemTrace.wakeupList[i]
          : undefined,
        currentCpu,
        true
      );
    };
  }

  render(cpuReq: RequestMessage, list: Array<any>, filter: Array<any>, translateY: number) {
    if (cpuReq.lazyRefresh) {
      this.cpu(
        list,
        filter,
        cpuReq.startNS,
        cpuReq.endNS,
        cpuReq.totalNS,
        cpuReq.frame,
        cpuReq.useCache || !cpuReq.range.refresh
      );
    } else {
      if (!cpuReq.useCache) {
        this.cpu(list, filter, cpuReq.startNS, cpuReq.endNS, cpuReq.totalNS, cpuReq.frame, false);
      }
    }
    if (cpuReq.canvas) {
      cpuReq.context.clearRect(0, 0, cpuReq.frame.width, cpuReq.frame.height);
      let arr = filter;
      if (arr.length > 0 && !cpuReq.range.refresh && !cpuReq.useCache && cpuReq.lazyRefresh) {
        drawLoading(
          cpuReq.context,
          cpuReq.startNS,
          cpuReq.endNS,
          cpuReq.totalNS,
          cpuReq.frame,
          arr[0].startTime,
          arr[arr.length - 1].startTime + arr[arr.length - 1].dur
        );
      }
      cpuReq.context.beginPath();
      drawLines(cpuReq.context, cpuReq.xs, cpuReq.frame.height, cpuReq.lineColor);
      CpuStruct.hoverCpuStruct = undefined;
      if (cpuReq.isHover) {
        for (let re of filter) {
          if (
            re.frame &&
            cpuReq.hoverX >= re.frame.x &&
            cpuReq.hoverX <= re.frame.x + re.frame.width &&
            cpuReq.hoverY >= re.frame.y &&
            cpuReq.hoverY <= re.frame.y + re.frame.height
          ) {
            CpuStruct.hoverCpuStruct = re;
            break;
          }
        }
      } else {
        CpuStruct.hoverCpuStruct = cpuReq.params.hoverCpuStruct;
      }
      CpuStruct.selectCpuStruct = cpuReq.params.selectCpuStruct;
      cpuReq.context.font = '11px sans-serif';
      for (let re of filter) {
        CpuStruct.draw(cpuReq.context, re, translateY);
      }
      drawSelection(cpuReq.context, cpuReq.params);
      cpuReq.context.closePath();
      drawFlagLine(
        cpuReq.context,
        cpuReq.flagMoveInfo,
        cpuReq.flagSelectedInfo,
        cpuReq.startNS,
        cpuReq.endNS,
        cpuReq.totalNS,
        cpuReq.frame,
        cpuReq.slicesTime
      );
    }
    // @ts-ignore
    self.postMessage({
      id: cpuReq.id,
      type: cpuReq.type,
      results: cpuReq.canvas ? undefined : filter,
      hover: CpuStruct.hoverCpuStruct,
    });
  }

  cpu(
    cpuList: Array<any>,
    cpuRes: Array<any>,
    startNS: number,
    endNS: number,
    totalNS: number,
    frame: any,
    use: boolean
  ) {
    if (use && cpuRes.length > 0) {
      let pns = (endNS - startNS) / frame.width;
      let y = frame.y + 5;
      let height = frame.height - 10;
      for (let i = 0, len = cpuRes.length; i < len; i++) {
        let it = cpuRes[i];
        if ((it.startTime || 0) + (it.dur || 0) > startNS && (it.startTime || 0) < endNS) {
          if (!cpuRes[i].frame) {
            cpuRes[i].frame = {};
            cpuRes[i].frame.y = y;
            cpuRes[i].frame.height = height;
          }
          CpuStruct.setCpuFrame(cpuRes[i], pns, startNS, endNS, frame);
        } else {
          cpuRes[i].frame = null;
        }
      }
      return;
    }
    if (cpuList) {
      cpuRes.length = 0;
      let pns = (endNS - startNS) / frame.width; //每个像素多少ns
      let y = frame.y + 5;
      let height = frame.height - 10;
      let left = 0,
        right = 0;
      for (let i = 0, j = cpuList.length - 1, ib = true, jb = true; i < cpuList.length, j >= 0; i++, j--) {
        if (cpuList[j].startTime <= endNS && jb) {
          right = j;
          jb = false;
        }
        if (cpuList[i].startTime + cpuList[i].dur >= startNS && ib) {
          left = i;
          ib = false;
        }
        if (!ib && !jb) {
          break;
        }
      }
      let slice = cpuList.slice(left, right + 1);
      let sum = 0;
      for (let i = 0; i < slice.length; i++) {
        if (!slice[i].frame) {
          slice[i].frame = {};
          slice[i].frame.y = y;
          slice[i].frame.height = height;
        }
        if (slice[i].dur >= pns) {
          slice[i].v = true;
          CpuStruct.setCpuFrame(slice[i], pns, startNS, endNS, frame);
        } else {
          if (i > 0) {
            let c = slice[i].startTime - slice[i - 1].startTime - slice[i - 1].dur;
            if (c < pns && sum < pns) {
              sum += c + slice[i - 1].dur;
              slice[i].v = false;
            } else {
              slice[i].v = true;
              CpuStruct.setCpuFrame(slice[i], pns, startNS, endNS, frame);
              sum = 0;
            }
          }
        }
      }
      cpuRes.push(...slice.filter((it) => it.v));
    }
  }
}

export class CpuStruct extends BaseStruct {
  static cpuCount: number = 1; //最大cpu数量
  static hoverCpuStruct: CpuStruct | undefined;
  static selectCpuStruct: CpuStruct | undefined;
  static wakeupBean: WakeupBean | null | undefined = null;
  cpu: number | undefined;
  dur: number | undefined;
  end_state: string | undefined;
  id: number | undefined;
  tid: number | undefined;
  name: string | undefined;
  priority: number | undefined;
  processCmdLine: string | undefined;
  processId: number | undefined;
  processName: string | undefined;
  displayProcess: string | undefined;
  displayThread: string | undefined;
  measurePWidth: number = 0;
  measureTWidth: number = 0;
  startTime: number | undefined;
  argSetID: number | undefined;
  type: string | undefined;
  v: boolean = false;
  nofinish: boolean = false;
  static draw(ctx: CanvasRenderingContext2D, data: CpuStruct, translateY: number) {
    if (data.frame) {
      let width = data.frame.width || 0;
      if (data.tid === CpuStruct.hoverCpuStruct?.tid || !CpuStruct.hoverCpuStruct) {
        ctx.globalAlpha = 1;
        ctx.fillStyle = ColorUtils.colorForTid((data.processId || 0) > 0 ? data.processId || 0 : data.tid || 0);
      } else if (data.processId === CpuStruct.hoverCpuStruct?.processId) {
        ctx.globalAlpha = 0.6;
        ctx.fillStyle = ColorUtils.colorForTid((data.processId || 0) > 0 ? data.processId || 0 : data.tid || 0);
      } else {
        ctx.globalAlpha = 1;
        ctx.fillStyle = '#e0e0e0';
      }
      ctx.fillRect(data.frame.x, data.frame.y, width, data.frame.height);
      ctx.globalAlpha = 1;
      let textFillWidth = width - textPadding * 2;
      if (textFillWidth > 3) {
        if (data.displayProcess === undefined) {
          data.displayProcess = `${data.processName || 'Process'} [${data.processId}]`;
          data.measurePWidth = ctx.measureText(data.displayProcess).width;
        }
        if (data.displayThread === undefined) {
          data.displayThread = `${data.name || 'Thread'} [${data.tid}] [Prio:${data.priority || 0}]`;
          data.measureTWidth = ctx.measureText(data.displayThread).width;
        }
        let processCharWidth = Math.round(data.measurePWidth / data.displayProcess.length);
        let threadCharWidth = Math.round(data.measureTWidth / data.displayThread.length);
        ctx.fillStyle = '#ffffff';
        let y = data.frame.height / 2 + data.frame.y;
        if (data.measurePWidth < textFillWidth) {
          let x1 = Math.floor(width / 2 - data.measurePWidth / 2 + data.frame.x + textPadding);
          ctx.textBaseline = 'bottom';
          ctx.fillText(data.displayProcess, x1, y, textFillWidth);
        } else {
          if (textFillWidth >= processCharWidth) {
            let chatNum = textFillWidth / processCharWidth;
            let x1 = data.frame.x + textPadding;
            ctx.textBaseline = 'bottom';
            if (chatNum < 2) {
              ctx.fillText(data.displayProcess.substring(0, 1), x1, y, textFillWidth);
            } else {
              ctx.fillText(data.displayProcess.substring(0, chatNum - 1) + '...', x1, y, textFillWidth);
            }
          }
        }
        ctx.fillStyle = '#ffffff';
        ctx.font = '9px sans-serif';
        if (data.measureTWidth < textFillWidth) {
          ctx.textBaseline = 'top';
          let x2 = Math.floor(width / 2 - data.measureTWidth / 2 + data.frame.x + textPadding);
          ctx.fillText(data.displayThread, x2, y + 2, textFillWidth);
        } else {
          if (textFillWidth >= threadCharWidth) {
            let chatNum = textFillWidth / threadCharWidth;
            let x1 = data.frame.x + textPadding;
            ctx.textBaseline = 'top';
            if (chatNum < 2) {
              ctx.fillText(data.displayThread.substring(0, 1), x1, y + 2, textFillWidth);
            } else {
              ctx.fillText(data.displayThread.substring(0, chatNum - 1) + '...', x1, y + 2, textFillWidth);
            }
          }
        }
      }
      if (data.nofinish && width > 4) {
        ctx.fillStyle = '#FFFFFF';
        let ruptureWidth = 4;
        let ruptureNode = 8;
        ctx.moveTo(data.frame.x + data.frame.width - 1, data.frame.y);
        for (let i = 1; i <= ruptureNode; i++) {
          ctx.lineTo(
            data.frame.x + data.frame.width - 1 - (i % 2 == 0 ? 0 : ruptureWidth),
            data.frame.y + (data.frame.height / ruptureNode) * i
          );
        }
        ctx.closePath();
        ctx.fill();
      }
      if (CpuStruct.selectCpuStruct && CpuStruct.equals(CpuStruct.selectCpuStruct, data)) {
        ctx.strokeStyle = '#232c5d';
        ctx.lineWidth = 2;
        ctx.strokeRect(data.frame.x, data.frame.y, width - 2, data.frame.height);
      }
    }
  }

  static setCpuFrame(cpuNode: any, pns: number, startNS: number, endNS: number, frame: any) {
    if ((cpuNode.startTime || 0) < startNS) {
      cpuNode.frame.x = 0;
    } else {
      cpuNode.frame.x = Math.floor(((cpuNode.startTime || 0) - startNS) / pns);
    }
    if ((cpuNode.startTime || 0) + (cpuNode.dur || 0) > endNS) {
      cpuNode.frame.width = frame.width - cpuNode.frame.x;
    } else {
      cpuNode.frame.width = Math.ceil(
        ((cpuNode.startTime || 0) + (cpuNode.dur || 0) - startNS) / pns - cpuNode.frame.x
      );
    }
    if (cpuNode.frame.width < 1) {
      cpuNode.frame.width = 1;
    }
  }

  static equals(d1: CpuStruct, d2: CpuStruct): boolean {
    return (
      d1 &&
      d2 &&
      d1.cpu == d2.cpu &&
      d1.tid == d2.tid &&
      d1.processId == d2.processId &&
      d1.startTime == d2.startTime &&
      d1.dur == d2.dur
    );
  }
}

export class WakeupBean {
  wakeupTime: number | undefined;
  cpu: number | undefined;
  process: string | undefined;
  pid: number | undefined;
  thread: string | undefined;
  tid: number | undefined;
  schedulingLatency: number | undefined;
  schedulingDesc: string | undefined;
  ts: number | undefined;
  itid: number | undefined;
}

const textPadding = 2;