cep/executor/processor_equal.go

package executor

import (
	schemepkg "git.buran.team/main/cep/scheme"
)

type EqualProcessor struct {
	content []byte
}

func NewEqualProcessor(processorScheme schemepkg.Processor) (*EqualProcessor, error) {
	// Normalize
	content := processorScheme.KindEqual.Content
	if len(content) > 0 && content[len(content)-1] == '\n' {
		content = content[:len(content)-1]
	}

	return &EqualProcessor{
		content: []byte(content),
	}, nil
}

func (this *EqualProcessor) Process(buffer []byte) bool {
	// Normalize
	if len(buffer) > 0 && buffer[len(buffer)-1] == '\n' {
		buffer = buffer[:len(buffer)-1]
	}

	// Compare
	if len(buffer) != len(this.content) {
		return false
	}

	for i := range buffer {
		if buffer[i] != this.content[i] {
			return false
		}
	}

	return true
}