#if !DISABLE_DHT // // Message.cs // // Authors: // Alan McGovern // // Copyright (C) 2008 Alan McGovern // // Permission is hereby granted, free of charge, to any person obtaining // a copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to // permit persons to whom the Software is furnished to do so, subject to // the following conditions: // // The above copyright notice and this permission notice shall be // included in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // using System; using System.Collections.Generic; using Tancoder.Torrent.BEncoding; using System.Net; using Tancoder.Torrent.Common; namespace Tancoder.Torrent.Dht.Messages { public abstract class DhtMessage : Tancoder.Torrent.Client.Messages.Message { public static bool UseVersionKey = true; private static BEncodedString EmptyString = ""; protected static readonly BEncodedString IdKey = "id"; private static BEncodedString TransactionIdKey = "t"; private static BEncodedString VersionKey = "v"; private static BEncodedString MessageTypeKey = "y"; private static BEncodedString DhtVersion = VersionInfo.DhtClientVersion; protected BEncodedDictionary properties = new BEncodedDictionary(); public BEncodedString ClientVersion { get { BEncodedValue val; if (properties.TryGetValue(VersionKey, out val)) return (BEncodedString)val; return EmptyString; } } public abstract NodeId Id { get; } public BEncodedString MessageType { get { return (BEncodedString)properties[MessageTypeKey]; } } public BEncodedValue TransactionId { get { return properties[TransactionIdKey]; } set { properties[TransactionIdKey] = value; } } protected DhtMessage(BEncodedString messageType) { properties.Add(TransactionIdKey, null); properties.Add(MessageTypeKey, messageType); if (UseVersionKey) properties.Add(VersionKey, DhtVersion); } protected DhtMessage(BEncodedDictionary dictionary) { properties = dictionary; } public override int ByteLength { get { return properties.LengthInBytes(); } } public override void Decode(byte[] buffer, int offset, int length) { properties = BEncodedValue.Decode(buffer, offset, length, false); } public override int Encode(byte[] buffer, int offset) { return properties.Encode(buffer, offset); } public virtual void Handle(IDhtEngine engine, Node node) { node.Seen(); } } } #endif