chat/storage/outbox.go

147 	obox, err := o.readStorage(ctx)
152 		obox = diskOutbox{
172 	for _, obr := range obox.Records {
191 	obox.Records = append(obox.Records, rec)
206 	obox.Version = outboxVersion
207 	if err = o.writeStorage(ctx, obox); err != nil {
221 	obox, err := o.readStorage(ctx)
227 	for _, obr := range obox.Records {
245 		obox.Records = errors
246 		obox.Version = outboxVersion
247 		if err := o.writeStorage(ctx, obox); err != nil {
262 	obox, err := o.readStorage(ctx)
267 		obox = diskOutbox{
276 	for _, obr := range obox.Records {
302 	obox.Records = recs
303 	if err := o.writeStorage(ctx, obox); err != nil {
313 	obox, err := o.readStorage(ctx)
318 	for _, iobr := range obox.Records {
331 	obox.Records = recs
332 	if err := o.writeStorage(ctx, obox); err != nil {
345 	obox, err := o.readStorage(ctx)
353 	for _, iobr := range obox.Records {
369 	obox.Records = recs
370 	if err := o.writeStorage(ctx, obox); err != nil {
382 	obox, err := o.readStorage(ctx)
389 	for _, obr := range obox.Records {
403 	obox.Records = recs
404 	if err := o.writeStorage(ctx, obox); err != nil {
413 	obox, err := o.readStorage(ctx)
417 	for _, obr := range obox.Records {
428 	obox, err := o.readStorage(ctx)
434 	for _, obr := range obox.Records {
442 	obox.Records = recs
443 	if err := o.writeStorage(ctx, obox); err != nil {
454 	obox, err := o.readStorage(ctx)
464 	for _, obr := range obox.Records {
472 	obox.Records = recs
475 	if err := o.writeStorage(ctx, obox); err != nil {
486 	obox, err := o.readStorage(ctx)
493 	for _, obr := range obox.Records {
501 	obox.Records = recs
504 	return res, o.writeStorage(ctx, obox)
513 	obox, err := o.readStorage(ctx)
527 	for _, obr := range obox.Records {
575 	obox, err := o.readStorage(ctx)
581 	for _, obr := range obox.Records {
607 	obox.Records = recs
610 	if err := o.writeStorage(ctx, obox); err != nil {
630 	obox, err := o.readStorage(ctx)
636 	for _, obr := range obox.Records {