<commit_before>package zeromq

import (
	"errors"

	"github.com/zeromq/gozmtp"
)

type Socket interface {
	Recv() ([]byte, error)
	Send([]byte) error
}

type socket struct{}

var (
	ClientSocketType = zmtp.ClientSocketType
	ServerSocketType = zmtp.ServerSocketType

	NullSecurityMechanism  = zmtp.NullSecurityMechanismType
	PlainSecurityMechanism = zmtp.PlainSecurityMechanismType
	CurveSecurityMechanism = zmtp.CurveSecurityMechanismType

	ErrNotImplemented = errors.New("not implemented")
)

func NewSecurityNull() *zmtp.SecurityNull {
	return &zmtp.SecurityNull{}
}

func NewSocket(socktype zmtp.SocketType, endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return &socket{}, ErrNotImplemented
}

func NewClient(endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return NewSocket(ClientSocketType, endpoint, mechanism)
}

func NewServer(endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return NewSocket(ServerSocketType, endpoint, mechanism)
}

func (s *socket) Recv() ([]byte, error) {
	var msg []byte
	return msg, ErrNotImplemented
}

func (s *socket) Send([]byte) error {
	return ErrNotImplemented
}<commit_msg>Problem: security names did not match zmtp versions<commit_after>package zeromq

import (
	"errors"

	"github.com/zeromq/gozmtp"
)

type Socket interface {
	Recv() ([]byte, error)
	Send([]byte) error
}

type socket struct{}

var (
	ClientSocketType = zmtp.ClientSocketType
	ServerSocketType = zmtp.ServerSocketType

	NullSecurityMechanismType  = zmtp.NullSecurityMechanismType
	PlainSecurityMechanismType = zmtp.PlainSecurityMechanismType
	CurveSecurityMechanismTyp  = zmtp.CurveSecurityMechanismType

	ErrNotImplemented = errors.New("not implemented")
)

func NewSecurityNull() *zmtp.SecurityNull {
	return zmtp.NewSecurityNull()
}

func NewSocket(socktype zmtp.SocketType, endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return &socket{}, ErrNotImplemented
}

func NewClient(endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return NewSocket(ClientSocketType, endpoint, mechanism)
}

func NewServer(endpoint string, mechanism zmtp.SecurityMechanism) (Socket, error) {
	return NewSocket(ServerSocketType, endpoint, mechanism)
}

func (s *socket) Recv() ([]byte, error) {
	var msg []byte
	return msg, ErrNotImplemented
}

func (s *socket) Send([]byte) error {
	return ErrNotImplemented
}
{'fraction_non_alphanumeric': 0.09975062344139651, 'fraction_numerical': 0.0, 'mean_word_length': 6.452012383900929, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3970795', 'n_tokens_mistral': 802, 'n_tokens_neox': 797, 'n_words': 183}