/*
 * Copyright DataStax, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.datastax.oss.protocol.internal.response.event;

import static com.datastax.oss.protocol.internal.ProtocolConstants.Version.V4;

import com.datastax.oss.protocol.internal.Message;
import com.datastax.oss.protocol.internal.PrimitiveCodec;
import com.datastax.oss.protocol.internal.PrimitiveSizes;
import com.datastax.oss.protocol.internal.ProtocolConstants;
import com.datastax.oss.protocol.internal.ProtocolErrors;
import com.datastax.oss.protocol.internal.response.Event;
import java.util.List;

public class SchemaChangeEvent extends Event {
  
See Also:
/** @see ProtocolConstants.SchemaChangeType */
public final String changeType;
See Also:
/** @see ProtocolConstants.SchemaChangeTarget */
public final String target; public final String keyspace; public final String object; public final List<String> arguments; public SchemaChangeEvent( String changeType, String target, String keyspace, String object, List<String> arguments) { super(ProtocolConstants.EventType.SCHEMA_CHANGE); this.changeType = changeType; this.target = target; this.keyspace = keyspace; this.object = object; this.arguments = arguments; } @Override public String toString() { return String.format( "EVENT SCHEMA_CHANGE(%s %s %s%s%s)", changeType, target, keyspace, (object == null) ? "" : "." + object, (arguments == null) ? "" : arguments); } public static class SubCodec extends Event.SubCodec { public SubCodec(int protocolVersion) { super(ProtocolConstants.EventType.SCHEMA_CHANGE, protocolVersion); } @Override public <B> void encode(B dest, Message message, PrimitiveCodec<B> encoder) { SchemaChangeEvent event = (SchemaChangeEvent) message; encoder.writeString(event.changeType, dest); encoder.writeString(event.target, dest); encoder.writeString(event.keyspace, dest); switch (event.target) { case ProtocolConstants.SchemaChangeTarget.KEYSPACE: break; case ProtocolConstants.SchemaChangeTarget.TABLE: case ProtocolConstants.SchemaChangeTarget.TYPE: encoder.writeString(event.object, dest); break; case ProtocolConstants.SchemaChangeTarget.AGGREGATE: case ProtocolConstants.SchemaChangeTarget.FUNCTION: encoder.writeString(event.object, dest); encoder.writeStringList(event.arguments, dest); break; default: throw new IllegalArgumentException("Unknown schema change target: " + event.target); } } @Override public int encodedSize(Message message) { SchemaChangeEvent event = (SchemaChangeEvent) message; ProtocolErrors.check( protocolVersion >= V4 || (!ProtocolConstants.SchemaChangeTarget.AGGREGATE.equals(event.target) && !ProtocolConstants.SchemaChangeTarget.FUNCTION.equals(event.target)), "%s schema change events are not supported in protocol version %d", event.target, protocolVersion); int size = PrimitiveSizes.sizeOfString(event.changeType); size += PrimitiveSizes.sizeOfString(event.target); size += PrimitiveSizes.sizeOfString(event.keyspace); switch (event.target) { case ProtocolConstants.SchemaChangeTarget.KEYSPACE: break; case ProtocolConstants.SchemaChangeTarget.TABLE: case ProtocolConstants.SchemaChangeTarget.TYPE: size += PrimitiveSizes.sizeOfString(event.object); break; case ProtocolConstants.SchemaChangeTarget.AGGREGATE: case ProtocolConstants.SchemaChangeTarget.FUNCTION: size += PrimitiveSizes.sizeOfString(event.object); size += PrimitiveSizes.sizeOfStringList(event.arguments); break; default: throw new IllegalArgumentException("Unknown schema change target: " + event.target); } return size; } @Override public <B> Message decode(B source, PrimitiveCodec<B> decoder) { String changeType = decoder.readString(source); String target = decoder.readString(source); ProtocolErrors.check( protocolVersion >= V4 || (!ProtocolConstants.SchemaChangeTarget.AGGREGATE.equals(target) && !ProtocolConstants.SchemaChangeTarget.FUNCTION.equals(target)), "%s schema change events are not supported in protocol version %d", target, protocolVersion); String keyspace = decoder.readString(source); String object; List<String> arguments; switch (target) { case ProtocolConstants.SchemaChangeTarget.KEYSPACE: object = null; arguments = null; break; case ProtocolConstants.SchemaChangeTarget.TABLE: case ProtocolConstants.SchemaChangeTarget.TYPE: object = decoder.readString(source); arguments = null; break; case ProtocolConstants.SchemaChangeTarget.AGGREGATE: case ProtocolConstants.SchemaChangeTarget.FUNCTION: object = decoder.readString(source); arguments = decoder.readStringList(source); break; default: throw new IllegalArgumentException("Unknown schema change target: " + target); } return new SchemaChangeEvent(changeType, target, keyspace, object, arguments); } } }