import { parseNumeral, Pattern, averageArray } from '@strudel/core';
import { Invoke } from './utils.mjs';

let offsetTime;
let timeAtPrevOffsetSample;
let prevOffsetTimes = [];

Pattern.prototype.osc = function () {
  return this.onTrigger(async (time, hap, currentTime, cps = 1, targetTime) => {
    hap.ensureObjectValue();
    const cycle = hap.wholeOrPart().begin.valueOf();
    const delta = hap.duration.valueOf();
    const controls = Object.assign({}, { cps, cycle, delta }, hap.value);
    // make sure n and note are numbers
    controls.n && (controls.n = parseNumeral(controls.n));
    controls.note && (controls.note = parseNumeral(controls.note));

    const params = [];

    const unixTimeSecs = Date.now() / 1000;
    const newOffsetTime = unixTimeSecs - currentTime;
    if (offsetTime == null) {
      offsetTime = newOffsetTime;
    }
    prevOffsetTimes.push(newOffsetTime);
    if (prevOffsetTimes.length > 8) {
      prevOffsetTimes.shift();
    }
    // every two seconds, the average of the previous 8 offset times is calculated and used as a stable reference
    // for calculating the timestamp that will be sent to the backend
    if (timeAtPrevOffsetSample == null || unixTimeSecs - timeAtPrevOffsetSample > 2) {
      timeAtPrevOffsetSample = unixTimeSecs;
      const rollingOffsetTime = averageArray(prevOffsetTimes);
      //account for the js clock freezing or resets set the new offset
      if (Math.abs(rollingOffsetTime - offsetTime) > 0.01) {
        offsetTime = rollingOffsetTime;
      }
    }

    const timestamp = offsetTime + targetTime;

    Object.keys(controls).forEach((key) => {
      const val = controls[key];
      const value = typeof val === 'number' ? val.toString() : val;

      if (value == null) {
        return;
      }
      params.push({
        name: key,
        value,
        valueisnumber: typeof val === 'number',
      });
    });

    if (params.length === 0) {
      return;
    }
    const message = { target: '/dirt/play', timestamp, params };
    setTimeout(() => {
      Invoke('sendosc', { messagesfromjs: [message] });
    });
  });
};