/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you 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 * * https://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. */ using System; namespace Avro.Util { /// /// The 'time-millis' logical type. /// public class TimeMillisecond : LogicalUnixEpochType { private static readonly TimeSpan _maxTime = new TimeSpan(23, 59, 59); /// /// The logical type name for TimeMillisecond. /// public static readonly string LogicalTypeName = "time-millis"; /// /// Initializes a new TimeMillisecond logical type. /// public TimeMillisecond() : base(LogicalTypeName) { } /// public override void ValidateSchema(LogicalSchema schema) { if (Schema.Type.Int != schema.BaseSchema.Tag) throw new AvroTypeException("'time-millis' can only be used with an underlying int type"); } /// public override object ConvertToBaseValue(object logicalValue, LogicalSchema schema) { var time = (TimeSpan)logicalValue; if (time > _maxTime) throw new ArgumentOutOfRangeException(nameof(logicalValue), "A 'time-millis' value can only have the range '00:00:00' to '23:59:59'."); return (int)(time - UnixEpochDateTime.TimeOfDay).TotalMilliseconds; } /// public override object ConvertToLogicalValue(object baseValue, LogicalSchema schema) { var noMs = (int)baseValue; return UnixEpochDateTime.TimeOfDay.Add(TimeSpan.FromMilliseconds(noMs)); } } }