Function sendSummary

cli/cmd/summary.go:150–203

(writeClient safeWriteClient, destinationSpec specs.Destination, destinationsClient *managedplugin.Client, destinationTransformer *transformer.RecordTransformer, summary *syncSummary, noMigrate bool)

}

func sendSummary(writeClient safeWriteClient, destinationSpec specs.Destination, destinationsClient *managedplugin.Client, destinationTransformer *transformer.RecordTransformer, summary *syncSummary, noMigrate bool) error {
	summaryTable, err := generateSummaryTable()
	if err != nil {
		return err
	}

	csr := caser.New(caser.WithCustomInitialisms(map[string]bool{"CLI": true}), caser.WithCustomExceptions(map[string]string{"cli": "CLI"}))

	// Respect the noMigrate flag
	if !noMigrate {
		if err := migrateSummaryTable(writeClient, destinationTransformer, destinationSpec); err != nil {
			return fmt.Errorf("failed to migrate sync summary table: %w", err)
		}
	}

	// Get Information about the DestinationPlugin
	m := destinationsClient.Metrics()
	summary.DestinationErrors = m.Errors
	summary.DestinationWarnings = m.Warnings

	summary.DestinationName = destinationSpec.Name
	summary.DestinationVersion = destinationSpec.Version
	summary.DestinationPath = destinationSpec.Path

	resource := schema.NewResourceData(summaryTable, nil, nil)
	for _, col := range summaryTable.Columns {
		// Use funk.Get to get the value from the summary struct using the column name converted to PascalCase
		err := resource.Set(col.Name, funk.Get(summary, csr.ToPascal(col.Name), funk.WithAllowZero()))
		if err != nil {
			return fmt.Errorf("failed to set %s: %w", col.Name, err)
		}
	}

	vector := resource.GetValues()
	arrowRecord := vector.ToArrowRecord(resource.Table.ToArrowSchema())

	transformedRecord := destinationTransformer.Transform(arrowRecord)
	transformedRecordBytes, err := plugin.RecordToBytes(transformedRecord)
	if err != nil {
		return fmt.Errorf("failed to transform sync summary bytes: %w", err)
	}

	wr := &plugin.Write_Request{}
	wr.Message = &plugin.Write_Request_Insert{
		Insert: &plugin.Write_MessageInsert{
			Record: transformedRecordBytes,
		},
	}
	if err := writeClient.Send(wr); err != nil {
		return handleSendError(err, writeClient, "insert sync summary")
	}

	return nil
}