Skip to content

Commit c32cf88

Browse files
authored
MINOR fix fullname of field passed to rule (#137)
1 parent b490d87 commit c32cf88

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

schemaregistry/serde/protobuf.ts

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -474,7 +474,7 @@ async function transformField(ctx: RuleContext, fd: DescField, desc: DescMessage
474474
try {
475475
ctx.enterField(
476476
msg,
477-
desc.name + '.' + fd.name,
477+
desc.typeName + '.' + fd.name,
478478
fd.name,
479479
getType(fd),
480480
getInlineTags(fd)
@@ -494,11 +494,13 @@ async function transformField(ctx: RuleContext, fd: DescField, desc: DescMessage
494494
}
495495

496496
function getType(fd: DescField): FieldType {
497-
switch (fd.fieldKind) {
497+
let kind = fd.fieldKind
498+
if (fd.fieldKind === 'list') {
499+
kind = fd.listKind
500+
}
501+
switch (kind) {
498502
case 'map':
499503
return FieldType.MAP
500-
case 'list':
501-
return FieldType.ARRAY
502504
case 'message':
503505
return FieldType.RECORD
504506
case 'enum':
@@ -526,6 +528,8 @@ function getType(fd: DescField): FieldType {
526528
return FieldType.DOUBLE
527529
case ScalarType.BOOL:
528530
return FieldType.BOOLEAN
531+
default:
532+
return FieldType.NULL
529533
}
530534
default:
531535
return FieldType.NULL

0 commit comments

Comments
 (0)