Function Operation

pkg/bundle/bundle.go:13–158

(arguments map[string]string, operation *base.Operation)

)

func Operation(arguments map[string]string, operation *base.Operation) (tb database.TupleBundle, ab database.AttributeBundle, err error) {
	rWrites := operation.GetRelationshipsWrite()

	// Initialize a TupleCollection to store the processed tuples.
	var wtc database.TupleCollection

	// Iterate over each write operation.
	for _, w := range rWrites {
		// Parse the write operation string into a template.
		tmpl, err := template.New("template").Option("missingkey=zero").Parse(w)
		if err != nil {
			return tb, ab, err
		}

		// Create a buffer to hold the template execution output.
		var buf bytes.Buffer

		// Execute the template with the provided arguments and store the output in the buffer.
		err = tmpl.Execute(&buf, arguments)
		if err != nil {
			return tb, ab, err
		}

		// Convert the write string into a tuple.
		t, err := tuple.Tuple(buf.String())
		if err != nil {
			return tb, ab, err
		}

		// Add the tuple to the write tuple collection.
		wtc.Add(t)
	}

	// Assign the processed write tuples to the tuple bundle.
	tb.Write = wtc

	// Retrieve the delete operations from the operation object.
	rDeletes := operation.GetRelationshipsDelete()

	// Initialize a TupleCollection to store the delete tuples.
	var dtc database.TupleCollection

	// Iterate over each delete operation.
	for _, w := range rDeletes {
		// Parse the write operation string into a template.
		tmpl, err := template.New("template").Option("missingkey=zero").Parse(w)
		if err != nil {
			return tb, ab, err
		}

		// Create a buffer to hold the template execution output.
		var buf bytes.Buffer

		// Execute the template with the provided arguments and store the output in the buffer.
		err = tmpl.Execute(&buf, arguments)
		if err != nil {
			return tb, ab, err
		}