larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Interface updated to use servicer.

Browse Source
This commit is contained in:
Danny Adams 2023-01-06 16:11:44 -05:00
parent 8a919ead95
commit dd42105b3e
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/internal/connector/exchange/exchange_data_collection.go
View File

@ -279,11 +279,9 @@ func (col *Collection) streamItems(ctx context.Context) {
return return
} }
service := col.service.(*graph.Service)
byteCount, err := serializeFunc( byteCount, err := serializeFunc(
ctx, ctx,
service, col.service,
col.data, col.data,
response, response,
user) user)
@ -341,8 +339,7 @@ func getModTime(mt modTimer) time.Time {
// responses into data.Stream items contained within the Collection // responses into data.Stream items contained within the Collection
type GraphSerializeFunc func( type GraphSerializeFunc func(
ctx context.Context, ctx context.Context,
// TODO: Keepers: Not sure how to have the interface use Serialize without updating all the files. service graph.Servicer,
service *graph.Service,
dataChannel chan<- data.Stream, dataChannel chan<- data.Stream,
parsable absser.Parsable, parsable absser.Parsable,
user string, user string,
@ -352,7 +349,7 @@ type GraphSerializeFunc func(
// data.Stream objects. Returns an error the process finishes unsuccessfully. // data.Stream objects. Returns an error the process finishes unsuccessfully.
func serializeAndStreamEvent( func serializeAndStreamEvent(
ctx context.Context, ctx context.Context,
service *graph.Service, service graph.Servicer,
dataChannel chan<- data.Stream, dataChannel chan<- data.Stream,
parsable absser.Parsable, parsable absser.Parsable,
user string, user string,
@ -412,7 +409,7 @@ func serializeAndStreamEvent(
// serializeAndStreamContact is a GraphSerializeFunc for models.Contactable // serializeAndStreamContact is a GraphSerializeFunc for models.Contactable
func serializeAndStreamContact( func serializeAndStreamContact(
ctx context.Context, ctx context.Context,
service *graph.Service, service graph.Servicer,
dataChannel chan<- data.Stream, dataChannel chan<- data.Stream,
parsable absser.Parsable, parsable absser.Parsable,
user string, user string,
@ -442,7 +439,7 @@ func serializeAndStreamContact(
// serializeAndStreamMessage is the GraphSerializeFunc for models.Messageable // serializeAndStreamMessage is the GraphSerializeFunc for models.Messageable
func serializeAndStreamMessage( func serializeAndStreamMessage(
ctx context.Context, ctx context.Context,
service *graph.Service, service graph.Servicer,
dataChannel chan<- data.Stream, dataChannel chan<- data.Stream,
parsable absser.Parsable, parsable absser.Parsable,
user string, user string,