diff --git a/dagsync/ipnisync/sync.go b/dagsync/ipnisync/sync.go index d2889f4..899b1da 100644 --- a/dagsync/ipnisync/sync.go +++ b/dagsync/ipnisync/sync.go @@ -241,7 +241,7 @@ func (s *Syncer) Sync(ctx context.Context, nextCid cid.Cid, sel ipld.Node) error reqType, ok := ctx.Value(CidSchemaHeader).(string) if ok { switch reqType { - case CidSchemaAd, CidSchemaEntries, "": + case CidSchemaAd, CidSchemaEntries: default: return fmt.Errorf("invalid cid schema type: %s", reqType) } @@ -329,7 +329,7 @@ retry: } reqType, ok := ctx.Value(CidSchemaHeader).(string) - if ok && reqType != "" { + if ok { req.Header.Set(CidSchemaHeader, reqType) }