@@ -5,6 +5,10 @@ import { BlockResolver } from './block'
55import type { ResolutionContext } from './reference'
66
77vi . mock ( '@sim/logger' , ( ) => loggerMock )
8+ vi . mock ( '@/blocks/registry' , async ( ) => {
9+ const actual = await vi . importActual < typeof import ( '@/blocks/registry' ) > ( '@/blocks/registry' )
10+ return actual
11+ } )
812
913function createTestWorkflow (
1014 blocks : Array < {
@@ -131,7 +135,7 @@ describe('BlockResolver', () => {
131135 } )
132136
133137 it . concurrent ( 'should return undefined for non-existent path when no schema defined' , ( ) => {
134- const workflow = createTestWorkflow ( [ { id : 'source' } ] )
138+ const workflow = createTestWorkflow ( [ { id : 'source' , type : 'unknown_block_type' } ] )
135139 const resolver = new BlockResolver ( workflow )
136140 const ctx = createTestContext ( 'current' , {
137141 source : { existing : 'value' } ,
@@ -162,19 +166,16 @@ describe('BlockResolver', () => {
162166 const workflow = createTestWorkflow ( [
163167 {
164168 id : 'source' ,
165- outputs : {
166- requiredField : { type : 'string' , description : 'Always present' } ,
167- optionalField : { type : 'string' , description : 'Sometimes missing' } ,
168- } ,
169+ type : 'function' ,
169170 } ,
170171 ] )
171172 const resolver = new BlockResolver ( workflow )
172173 const ctx = createTestContext ( 'current' , {
173- source : { requiredField : 'value ' } ,
174+ source : { stdout : 'log output ' } ,
174175 } )
175176
176- expect ( resolver . resolve ( '<source.requiredField >' , ctx ) ) . toBe ( 'value ' )
177- expect ( resolver . resolve ( '<source.optionalField >' , ctx ) ) . toBeUndefined ( )
177+ expect ( resolver . resolve ( '<source.stdout >' , ctx ) ) . toBe ( 'log output ' )
178+ expect ( resolver . resolve ( '<source.result >' , ctx ) ) . toBeUndefined ( )
178179 } )
179180
180181 it . concurrent (
@@ -1012,7 +1013,7 @@ describe('BlockResolver', () => {
10121013 } )
10131014
10141015 it . concurrent ( 'should handle output with undefined values' , ( ) => {
1015- const workflow = createTestWorkflow ( [ { id : 'source' } ] )
1016+ const workflow = createTestWorkflow ( [ { id : 'source' , type : 'unknown_block_type' } ] )
10161017 const resolver = new BlockResolver ( workflow )
10171018 const ctx = createTestContext ( 'current' , {
10181019 source : { value : undefined , other : 'exists' } ,
@@ -1022,7 +1023,7 @@ describe('BlockResolver', () => {
10221023 } )
10231024
10241025 it . concurrent ( 'should return undefined for deeply nested non-existent path' , ( ) => {
1025- const workflow = createTestWorkflow ( [ { id : 'source' } ] )
1026+ const workflow = createTestWorkflow ( [ { id : 'source' , type : 'unknown_block_type' } ] )
10261027 const resolver = new BlockResolver ( workflow )
10271028 const ctx = createTestContext ( 'current' , {
10281029 source : { level1 : { level2 : { } } } ,
0 commit comments