Skip to content

Commit 394ccaa

Browse files
committed
feat: implement MixtapeLabs workflow graph with audio analysis pipeline
1 parent 3bcf5b2 commit 394ccaa

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/**
2-
* Mixtapelabs Workflow Graph - LangGraph Orchestration
2+
* MixtapeLabs Workflow Graph - LangGraph Orchestration
33
*
44
* Implements the complete audio analysis pipeline as a LangGraph state machine.
55
* The workflow is linear and fault-tolerant:
@@ -20,7 +20,7 @@
2020
*/
2121
import { Annotation, END, START, StateGraph } from '@langchain/langgraph';
2222
import type { EngineState } from '../state.ts';
23-
import type { MixtapelabsEngineDeps } from '../types.ts';
23+
import type { MixtapeLabsEngineDeps } from '../types.ts';
2424

2525
/**
2626
* LangGraph annotation defining the shape of our workflow state.
@@ -82,7 +82,7 @@ const GRAPH_NODE_NAMES = [
8282
*/
8383
export async function validateInputNode(state: GraphState): Promise<GraphNodeResult> {
8484
if (!state.uploadUrl) {
85-
return { error: 'uploadUrl is required to run an Mixtapelabs session' };
85+
return { error: 'uploadUrl is required to run an MixtapeLabs session' };
8686
}
8787

8888
return {};
@@ -103,7 +103,7 @@ export async function validateInputNode(state: GraphState): Promise<GraphNodeRes
103103
* @returns { fileInfo } on success, { error } on failure, or {} if skipped
104104
*/
105105
export async function metadataStepNode(
106-
deps: Pick<MixtapelabsEngineDeps, 'audioMetadataClient'>,
106+
deps: Pick<MixtapeLabsEngineDeps, 'audioMetadataClient'>,
107107
state: GraphState,
108108
): Promise<GraphNodeResult> {
109109
// Skip if no URL or already errored
@@ -137,7 +137,7 @@ export async function metadataStepNode(
137137
* @returns { analysis } on success, { error } on failure, or {} if skipped
138138
*/
139139
export async function analysisStepNode(
140-
deps: Pick<MixtapelabsEngineDeps, 'audioAnalysisClient'>,
140+
deps: Pick<MixtapeLabsEngineDeps, 'audioAnalysisClient'>,
141141
state: GraphState,
142142
): Promise<GraphNodeResult> {
143143
// Skip if no URL or already errored
@@ -173,7 +173,7 @@ export async function analysisStepNode(
173173
* @returns { feedbackText, suggestions } on success, { error } on failure, or {} if skipped
174174
*/
175175
export async function feedbackStepNode(
176-
deps: Pick<MixtapelabsEngineDeps, 'feedbackClient'>,
176+
deps: Pick<MixtapeLabsEngineDeps, 'feedbackClient'>,
177177
state: GraphState,
178178
): Promise<GraphNodeResult> {
179179
// Skip if already errored
@@ -193,7 +193,7 @@ export async function feedbackStepNode(
193193
}
194194

195195
/**
196-
* Constructs and compiles the complete Mixtapelabs workflow graph.
196+
* Constructs and compiles the complete MixtapeLabs workflow graph.
197197
*
198198
* This function:
199199
* 1. Creates a LangGraph StateGraph with our annotation
@@ -225,7 +225,7 @@ export async function feedbackStepNode(
225225
* @param deps - Complete set of injected service clients
226226
* @returns Compiled graph ready for execution via `.invoke(initialState)`
227227
*/
228-
export function buildMixtapelabsGraph(deps: MixtapelabsEngineDeps) {
228+
export function buildMixtapeLabsGraph(deps: MixtapeLabsEngineDeps) {
229229
const workflow = new StateGraph(GraphAnnotation, {
230230
nodes: GRAPH_NODE_NAMES,
231231
}) as StateGraph<typeof GraphAnnotation, GraphState, GraphNodeResult, GraphNodeName>;

0 commit comments

Comments
 (0)