+271

api/atproto/cbor_gen.go

reviewed

··· 935 935 936 936 return nil 937 937 } 938 938 + func (t *SyncSubscribeRepos_Sync) MarshalCBOR(w io.Writer) error { 939 939 + if t == nil { 940 940 + _, err := w.Write(cbg.CborNull) 941 941 + return err 942 942 + } 943 943 + 944 944 + cw := cbg.NewCborWriter(w) 945 945 + fieldCount := 5 946 946 + 947 947 + if t.Blocks == nil { 948 948 + fieldCount-- 949 949 + } 950 950 + 951 951 + if _, err := cw.Write(cbg.CborEncodeMajorType(cbg.MajMap, uint64(fieldCount))); err != nil { 952 952 + return err 953 953 + } 954 954 + 955 955 + // t.Did (string) (string) 956 956 + if len("did") > 1000000 { 957 957 + return xerrors.Errorf("Value in field \"did\" was too long") 958 958 + } 959 959 + 960 960 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("did"))); err != nil { 961 961 + return err 962 962 + } 963 963 + if _, err := cw.WriteString(string("did")); err != nil { 964 964 + return err 965 965 + } 966 966 + 967 967 + if len(t.Did) > 1000000 { 968 968 + return xerrors.Errorf("Value in field t.Did was too long") 969 969 + } 970 970 + 971 971 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Did))); err != nil { 972 972 + return err 973 973 + } 974 974 + if _, err := cw.WriteString(string(t.Did)); err != nil { 975 975 + return err 976 976 + } 977 977 + 978 978 + // t.Rev (string) (string) 979 979 + if len("rev") > 1000000 { 980 980 + return xerrors.Errorf("Value in field \"rev\" was too long") 981 981 + } 982 982 + 983 983 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("rev"))); err != nil { 984 984 + return err 985 985 + } 986 986 + if _, err := cw.WriteString(string("rev")); err != nil { 987 987 + return err 988 988 + } 989 989 + 990 990 + if len(t.Rev) > 1000000 { 991 991 + return xerrors.Errorf("Value in field t.Rev was too long") 992 992 + } 993 993 + 994 994 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Rev))); err != nil { 995 995 + return err 996 996 + } 997 997 + if _, err := cw.WriteString(string(t.Rev)); err != nil { 998 998 + return err 999 999 + } 1000 1000 + 1001 1001 + // t.Seq (int64) (int64) 1002 1002 + if len("seq") > 1000000 { 1003 1003 + return xerrors.Errorf("Value in field \"seq\" was too long") 1004 1004 + } 1005 1005 + 1006 1006 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("seq"))); err != nil { 1007 1007 + return err 1008 1008 + } 1009 1009 + if _, err := cw.WriteString(string("seq")); err != nil { 1010 1010 + return err 1011 1011 + } 1012 1012 + 1013 1013 + if t.Seq >= 0 { 1014 1014 + if err := cw.WriteMajorTypeHeader(cbg.MajUnsignedInt, uint64(t.Seq)); err != nil { 1015 1015 + return err 1016 1016 + } 1017 1017 + } else { 1018 1018 + if err := cw.WriteMajorTypeHeader(cbg.MajNegativeInt, uint64(-t.Seq-1)); err != nil { 1019 1019 + return err 1020 1020 + } 1021 1021 + } 1022 1022 + 1023 1023 + // t.Time (string) (string) 1024 1024 + if len("time") > 1000000 { 1025 1025 + return xerrors.Errorf("Value in field \"time\" was too long") 1026 1026 + } 1027 1027 + 1028 1028 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("time"))); err != nil { 1029 1029 + return err 1030 1030 + } 1031 1031 + if _, err := cw.WriteString(string("time")); err != nil { 1032 1032 + return err 1033 1033 + } 1034 1034 + 1035 1035 + if len(t.Time) > 1000000 { 1036 1036 + return xerrors.Errorf("Value in field t.Time was too long") 1037 1037 + } 1038 1038 + 1039 1039 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Time))); err != nil { 1040 1040 + return err 1041 1041 + } 1042 1042 + if _, err := cw.WriteString(string(t.Time)); err != nil { 1043 1043 + return err 1044 1044 + } 1045 1045 + 1046 1046 + // t.Blocks (util.LexBytes) (slice) 1047 1047 + if t.Blocks != nil { 1048 1048 + 1049 1049 + if len("blocks") > 1000000 { 1050 1050 + return xerrors.Errorf("Value in field \"blocks\" was too long") 1051 1051 + } 1052 1052 + 1053 1053 + if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("blocks"))); err != nil { 1054 1054 + return err 1055 1055 + } 1056 1056 + if _, err := cw.WriteString(string("blocks")); err != nil { 1057 1057 + return err 1058 1058 + } 1059 1059 + 1060 1060 + if len(t.Blocks) > 2097152 { 1061 1061 + return xerrors.Errorf("Byte array in field t.Blocks was too long") 1062 1062 + } 1063 1063 + 1064 1064 + if err := cw.WriteMajorTypeHeader(cbg.MajByteString, uint64(len(t.Blocks))); err != nil { 1065 1065 + return err 1066 1066 + } 1067 1067 + 1068 1068 + if _, err := cw.Write(t.Blocks); err != nil { 1069 1069 + return err 1070 1070 + } 1071 1071 + 1072 1072 + } 1073 1073 + return nil 1074 1074 + } 1075 1075 + 1076 1076 + func (t *SyncSubscribeRepos_Sync) UnmarshalCBOR(r io.Reader) (err error) { 1077 1077 + *t = SyncSubscribeRepos_Sync{} 1078 1078 + 1079 1079 + cr := cbg.NewCborReader(r) 1080 1080 + 1081 1081 + maj, extra, err := cr.ReadHeader() 1082 1082 + if err != nil { 1083 1083 + return err 1084 1084 + } 1085 1085 + defer func() { 1086 1086 + if err == io.EOF { 1087 1087 + err = io.ErrUnexpectedEOF 1088 1088 + } 1089 1089 + }() 1090 1090 + 1091 1091 + if maj != cbg.MajMap { 1092 1092 + return fmt.Errorf("cbor input should be of type map") 1093 1093 + } 1094 1094 + 1095 1095 + if extra > cbg.MaxLength { 1096 1096 + return fmt.Errorf("SyncSubscribeRepos_Sync: map struct too large (%d)", extra) 1097 1097 + } 1098 1098 + 1099 1099 + n := extra 1100 1100 + 1101 1101 + nameBuf := make([]byte, 6) 1102 1102 + for i := uint64(0); i < n; i++ { 1103 1103 + nameLen, ok, err := cbg.ReadFullStringIntoBuf(cr, nameBuf, 1000000) 1104 1104 + if err != nil { 1105 1105 + return err 1106 1106 + } 1107 1107 + 1108 1108 + if !ok { 1109 1109 + // Field doesn't exist on this type, so ignore it 1110 1110 + if err := cbg.ScanForLinks(cr, func(cid.Cid) {}); err != nil { 1111 1111 + return err 1112 1112 + } 1113 1113 + continue 1114 1114 + } 1115 1115 + 1116 1116 + switch string(nameBuf[:nameLen]) { 1117 1117 + // t.Did (string) (string) 1118 1118 + case "did": 1119 1119 + 1120 1120 + { 1121 1121 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 1122 1122 + if err != nil { 1123 1123 + return err 1124 1124 + } 1125 1125 + 1126 1126 + t.Did = string(sval) 1127 1127 + } 1128 1128 + // t.Rev (string) (string) 1129 1129 + case "rev": 1130 1130 + 1131 1131 + { 1132 1132 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 1133 1133 + if err != nil { 1134 1134 + return err 1135 1135 + } 1136 1136 + 1137 1137 + t.Rev = string(sval) 1138 1138 + } 1139 1139 + // t.Seq (int64) (int64) 1140 1140 + case "seq": 1141 1141 + { 1142 1142 + maj, extra, err := cr.ReadHeader() 1143 1143 + if err != nil { 1144 1144 + return err 1145 1145 + } 1146 1146 + var extraI int64 1147 1147 + switch maj { 1148 1148 + case cbg.MajUnsignedInt: 1149 1149 + extraI = int64(extra) 1150 1150 + if extraI < 0 { 1151 1151 + return fmt.Errorf("int64 positive overflow") 1152 1152 + } 1153 1153 + case cbg.MajNegativeInt: 1154 1154 + extraI = int64(extra) 1155 1155 + if extraI < 0 { 1156 1156 + return fmt.Errorf("int64 negative overflow") 1157 1157 + } 1158 1158 + extraI = -1 - extraI 1159 1159 + default: 1160 1160 + return fmt.Errorf("wrong type for int64 field: %d", maj) 1161 1161 + } 1162 1162 + 1163 1163 + t.Seq = int64(extraI) 1164 1164 + } 1165 1165 + // t.Time (string) (string) 1166 1166 + case "time": 1167 1167 + 1168 1168 + { 1169 1169 + sval, err := cbg.ReadStringWithMax(cr, 1000000) 1170 1170 + if err != nil { 1171 1171 + return err 1172 1172 + } 1173 1173 + 1174 1174 + t.Time = string(sval) 1175 1175 + } 1176 1176 + // t.Blocks (util.LexBytes) (slice) 1177 1177 + case "blocks": 1178 1178 + 1179 1179 + maj, extra, err = cr.ReadHeader() 1180 1180 + if err != nil { 1181 1181 + return err 1182 1182 + } 1183 1183 + 1184 1184 + if extra > 2097152 { 1185 1185 + return fmt.Errorf("t.Blocks: byte array too large (%d)", extra) 1186 1186 + } 1187 1187 + if maj != cbg.MajByteString { 1188 1188 + return fmt.Errorf("expected byte array") 1189 1189 + } 1190 1190 + 1191 1191 + if extra > 0 { 1192 1192 + t.Blocks = make([]uint8, extra) 1193 1193 + } 1194 1194 + 1195 1195 + if _, err := io.ReadFull(cr, t.Blocks); err != nil { 1196 1196 + return err 1197 1197 + } 1198 1198 + 1199 1199 + default: 1200 1200 + // Field doesn't exist on this type, so ignore it 1201 1201 + if err := cbg.ScanForLinks(r, func(cid.Cid) {}); err != nil { 1202 1202 + return err 1203 1203 + } 1204 1204 + } 1205 1205 + } 1206 1206 + 1207 1207 + return nil 1208 1208 + } 938 1209 func (t *SyncSubscribeRepos_Handle) MarshalCBOR(w io.Writer) error { 939 1210 if t == nil { 940 1211 _, err := w.Write(cbg.CborNull)

+1

gen/main.go

reviewed

··· 95 95 atproto.LexiconSchema{}, 96 96 atproto.RepoStrongRef{}, 97 97 atproto.SyncSubscribeRepos_Commit{}, 98 98 + atproto.SyncSubscribeRepos_Sync{}, 98 99 atproto.SyncSubscribeRepos_Handle{}, 99 100 atproto.SyncSubscribeRepos_Identity{}, 100 101 atproto.SyncSubscribeRepos_Account{},