package com.orchard.models;

import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.SchemaBuilder;
import org.apache.kafka.connect.data.Struct;

public class GPSocialAccountIds implements OrchardModel {

    public String spotify;

    public String appleMusic;

    public long chartmetric;

    public static final Schema KafkaSchema = SchemaBuilder.struct().optional()
            .field("spotify", org.apache.kafka.connect.data.Schema.OPTIONAL_STRING_SCHEMA)
            .field("appleMusic", org.apache.kafka.connect.data.Schema.OPTIONAL_STRING_SCHEMA)
            .field("chartmetric", org.apache.kafka.connect.data.Schema.OPTIONAL_INT64_SCHEMA)
            .build();

    public Struct ToKafkaStruct() {
        return new Struct(KafkaSchema)
                .put("spotify", spotify)
                .put("appleMusic", appleMusic)
                .put("chartmetric", chartmetric);
    }
}