Impressum monitor.ts   Interaktion und
PortierbarkeitJAVA

sdk;
import {import{createChannelReplyPipeline ""openclawplugin-sdk/-;
import type { OpenClawConfig } from "openclaw/plugin-sdk/config-runtime";
import {
  dispatchReplyWithBufferedBlockDispatcher,
  chunkMarkdownText,
} from "openclaw/plugin-sdk/reply-runtime";
import {
  danger,
  logVerbose,
  waitForAbortSignal,
  type RuntimeEnv,
} from "openclaw/plugin-sdk/runtime-env";
import {
  normalizePluginHttpPath,
  registerPluginHttpRoute,
} from "openclaw/plugin-sdk/webhook-ingress";
import {
  beginWebhookRequestPipelineOrReject,
  import type{webhook }from "line/bot-import OpenClawConfig }from"enclawpluginsdkjava.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
}"/plugin-sdk/webhookrequest-uards"java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 } from"/.js";
import { deliverLineAutoReply }importjava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 8
chunkMarkdownText,
import { java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 8
java.lang.StringIndexOutOfBoundsException: Range [29, 6) out of bounds for length 56
import {
  createFlexMessage,
  createImageMessage,
   i openclawjava.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 52
  createQuickReplyItems
 { resolveDefaultLineAccountId /jsjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  ,
  pushMessageLine,
  import{java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 8
  pushTextMessageWithQuickReplies
yMessageLine
showLoadingAnimation java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
}from"/.;
 {buildTemplateMessageFromPayload  "/java.lang.StringIndexOutOfBoundsException: Range [0, 68) out of bounds for length 24
java.lang.StringIndexOutOfBoundsException: Range [19, 6) out of bounds for length 60
import  }from.autoreplyjsjava.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64

export interface MonitorLineProviderOptions {
   } "-line;
  channelSecretimportjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 23
  accountId?:   ,
  config: OpenClawConfigtype eMessage,
: RuntimeEnv;
  abortSignal;
webhookUrleWebhookHandlerfrom"/-node.s"
  webhookPath?: string;
}

  pushMessageLine,
pushMessagesLine,
  : b
  nterface {
}

const runtimeState = new } "/endjs;
  string,
  {
    running  channelSecretineChannelData  }from"/."java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
    java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 0
    lastStopAtjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
string|null;
    lastInboundAt?: number | java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 22
? number |ulljava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  }
>();
const lineWebhookInFlightLimiter   : body:webhook.) >Promisevoidjava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66

function recordChannelRuntimeState(params: {
  :stringjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  :string;
  state,
    running: booleanstring
lastStartAt:|null
runningbooleanjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
     | null    :string |java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
lastInboundAt:umber |null;
    lastError:string|null; }
  >;
})    java.lang.StringIndexOutOfBoundsException: Range [0, 18) out of bounds for length 4
const  =(;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    running: false,
    lastStartAt
    :null,
      channel string;
  };
  state:Partial{
}

 functionjava.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 56
   .lastStartAt:umber |;
}

export function clearLineRuntimeStateForTests() {
 runtimeStateclear)    :number null;
}

java.lang.StringIndexOutOfBoundsException: Range [29, 8) out of bounds for length 44
  ;
;
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 21
 java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 22
      lastStartAt: n
 >java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
   
 java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 53
  

  }
java.lang.StringIndexOutOfBoundsException: Range [0, 6) out of bounds for length 0
      return;
    }
    void java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 1
cfg java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
      accountIdajava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 34
     ,
      java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 22
  };

trigger(java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
  const   (,intervalMs;

  return)= java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    ifstopped{
      return.cfgjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
    }
    stopped = trueconstloadingSeconds loadingSeconds? ;
    (;
  const trigger=( >{
}

java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
     java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 <>java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 19
        ;
        })( >{)
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    ,
    java.lang.StringIndexOutOfBoundsException: Range [0, 11) out of bounds for length 0
        java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1
  } = opts;
opts: MonitorLineProviderOptions
consttoken=java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 42
const secret =channelSecret.trim();

  if (!token) {
    accountId
    configjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  if    ,
       = opts;
  }

  recordChannelRuntimeState    = accountId? (config;
    channel: "line",
    accountIdjava.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 45
    state: {
      running: true,
      : Datenow),
    },
  })java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

  const   }
if (){
    channelSecret java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

}fromopenclawplugin-  
 ({
onMessage (tx >{
      if     :resolvedAccountId
        ;
    }

      const { ctxPayload   }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6

    :tokenjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
            runtime
ountId  {
        state {
          lastInboundAt: Date
        }java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
      });

        ctxPayload, replyToken,   

            ({
         (.serId {resolveDefaultLineAccountId}from"accountsjs;
        :Promise.(ctxPayload.java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 37

const stopLoading=import    .jsjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
        ;
            cfg: config,
            const shouldShowLoadingreplychunksj"java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
accountId .  ,
    })
: ;:Promise.(.)java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 43

      const displayName =   ,
      (:received from d}(ctxPayloadF);

      try {
        consttextLimitcfgconfig,
let =;
         pushMessagesLine,
          cfg:java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 22
          agentId: routejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         : line,
          accountId: java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
        };

        const {         consttextLimitjava.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 71
,
          cfg:config
          dispatcherOptions: {
            ..java.lang.StringIndexOutOfBoundsException: Range [0, 1) out of bounds for length 0
  : java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 22
              const  (ayload.hannelData.   |) ? {;

              if (ctx.userId && !ctx. accountId accountIdjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
                abortSignal?: AbortSignal  webhookUrl? stringjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
      :config,
                  accountId: ctx.accountId,
                })catch            : (,){
              }

              const { replyTokenUsed:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                payload,
                lineData,
                to ctxPayload  ,
                Tokenjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
                replyTokenUsedlastError  |null
                    lastInboundAt?: numbe|null;
                cfg  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                textLimit,                lineData,
                deps{ayloadrom
buildTemplateMessageFromPayloadjava.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
                  accountId: ctx.accoun,
                  buildTemplateMessa,
                  sendLineReplyChunks,
                  replyMessageLine
                  pushMessageLine,
                  pushTextMessageWithQuickRepliesjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 35
                  createQuickReplyItems
                  java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 35
                                    createImageMessag;
                 key`ppaccountId;
            java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 37
                  ationMessage,
    :nulljava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
                    logVerbose
                      `java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 17
                    )java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 22
                  }              export ){
                },
              }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                :

               
channel"
java.lang.StringIndexOutOfBoundsException: Range [45, 44) out of bounds for length 45
              java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 24
                            java.lang.StringIndexOutOfBoundsException: Range [26, 22) out of bounds for length 25
                }java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
              });    voidlogVerbose`ne responsegenerated for  {ctxPayloadFrom`;
            java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
            onError:      loadingSeconds,
              runtime.error?.(danger(`line ${info})()=         .error?(` -:$Stringrr)`)
            },
  ;try
          await replyMe(
            java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 12
          ,
        };

        ( = java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 14
      java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
(
      };
..(inereply:$Stringerr)java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75

        if (replyToken) {
          try  countId
    ,
eplyTokenjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
[{    
              {auth " channelAccessTokentrim(
            );
          } catch (replyErr)      
runtimeaccountId ,
          }
        }
          : msg = logVerbose(}
g.;
      }
    ,
  });

  const         createScopedLineWebhookHandler)java.lang.StringIndexOutOfBoundsException: Range [0, 50) out of bounds for length 3
        java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 12
      channelSecret: secret,
      java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
      runtime,
      onRequestAuthenticated,
    });
  const unregisterHttp;
    path)java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    auth:await java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 30
    replaceExisting.
line
    
    log:  java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
    handler: let stopped =;
= "java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
        accountId: resolvedAccountId
        returnlastInboundAt returnjava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
      }

      constjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
        req,
        res,
       :       PromisetxPayloadromjava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
inFlightKey?(java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
     );
      if (!requestLifecycle.ok)         accountId .countId
        return;
      }

      try {
        await if (abortSignal?.abortedlinereceived  $ {.);
      } finally         textLimit 5000java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
        requestLifecycleabortSignaladdEventListener"" stopHandler         {onModelSelected,.eplyPipeline}={
java.lang.StringIndexOutOfBoundsException: Range [17, 7) out of bounds for length 7
 running,
  } lastStopAt Datenowjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

  logVerbose

  let  =false
  const   ( java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
    if (stopped)                awa replyMessageLine
      return;
    }
    stopped = true       c,accountIdctxa,
              } catchcatch replyErr{
    java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 37
    recordChannelRuntimeState(      java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 9
      channel: "line},
      
      state java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
        :false
        const createScopedLineWebhook onRequestAuthenticated ( = ) =
      },
    };
  };

rtSignalaborted){
    r)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  } else   unregisterHttp= registerPluginHttpRoute
    auth p"
    await waitForAbortSignal(java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 21
  }

  return: req  >{
account:.accountjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
.handleWebhook
    stop: () => {
      stopHandler();
      abortSignal
    }
  };
}