1import * as _ from 'lodash-es'
2import { getKlusterCtx } from '../ctxF/klusterCtxF.mts'
3import { streamPodLogs } from './podLogsF.mts'
4import { isOpenCode } from '../../../sharedF/isDevPcF.mts'
5import { quietModeCtx, multiDeployCtx } from '../../../serverF/briefForLlmF.mts'
6
7// Skip streaming if in programmatic test context, opencode, multi-deploy sequence, or running under ptnode (already logging to file)
8export const shouldSkipStreamLogs = () => quietModeCtx.getStore()?.quiet || isOpenCode || multiDeployCtx.getStore()?.skipStreamLogs || process.env.PTNODE_LOG_PATH
9
10type WatchFlogsProps = {
11  doWatch?: boolean
12  name?: string
13  action?: string
14}
15
16export const watchFlogs = async (props1?: WatchFlogsProps) => {
17  const {doWatch=true, ...props} = props1 || {}
18  const {name, action, cluster_name} = _.merge(getKlusterCtx(), props) as {name: string, action: string, cluster_name: string}
19
20  if (!_.includes(['logs', 'apply'], action)) return
21
22  if (shouldSkipStreamLogs()) return
23
24  await streamPodLogs({name, cluster_name})
25}
26