File tree Expand file tree Collapse file tree 4 files changed +13
-9
lines changed Expand file tree Collapse file tree 4 files changed +13
-9
lines changed Original file line number Diff line number Diff line change @@ -150,11 +150,11 @@ export const SnsSqsEnvelope = {
150
150
} > (
151
151
( acc , record , index ) => {
152
152
const parsed = parseRecord ( record , index ) ;
153
- if ( ! parsed . success ) {
153
+ if ( parsed . success ) {
154
+ acc . records . push ( parsed . data ) ;
155
+ } else {
154
156
acc . success = false ;
155
157
acc . errors [ index ] = parsed . error ;
156
- } else {
157
- acc . records . push ( parsed . data ) ;
158
158
}
159
159
return acc ;
160
160
} ,
Original file line number Diff line number Diff line change @@ -169,12 +169,14 @@ const AppSyncEventsSubscribeSchema = AppSyncEventsBaseSchema.extend({
169
169
170
170
export {
171
171
AppSyncEventsBaseSchema ,
172
- AppSyncCognitoIdentity ,
173
- AppSyncIamIdentity ,
174
172
AppSyncLambdaAuthIdentity ,
175
- AppSyncOidcIdentity ,
176
173
AppSyncEventsRequestSchema ,
177
174
AppSyncEventsInfoSchema ,
178
175
AppSyncEventsPublishSchema ,
179
176
AppSyncEventsSubscribeSchema ,
180
177
} ;
178
+ export {
179
+ AppSyncCognitoIdentity ,
180
+ AppSyncIamIdentity ,
181
+ AppSyncOidcIdentity ,
182
+ } from './appsync-shared.js' ;
Original file line number Diff line number Diff line change @@ -236,8 +236,10 @@ const AppSyncBatchResolverSchema = z.array(AppSyncResolverSchema);
236
236
export {
237
237
AppSyncResolverSchema ,
238
238
AppSyncBatchResolverSchema ,
239
+ AppSyncLambdaIdentity ,
240
+ } ;
241
+ export {
239
242
AppSyncCognitoIdentity ,
240
243
AppSyncIamIdentity ,
241
244
AppSyncOidcIdentity ,
242
- AppSyncLambdaIdentity ,
243
- } ;
245
+ } from './appsync-shared.js' ;
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ const KafkaRecordSchema = z.object({
23
23
z . record (
24
24
z . string ( ) ,
25
25
z . array ( z . number ( ) ) . transform ( ( value ) => {
26
- return String . fromCharCode ( ...value ) ;
26
+ return String . fromCodePoint ( ...value ) ;
27
27
} )
28
28
)
29
29
) ,
You can’t perform that action at this time.
0 commit comments