Changeset 7 for ProtocolBuffers/UProtocolBuffers.pas

Timestamp:

Oct 9, 2009, 2:15:48 PM (15 years ago)

Author:

george

Message:

• Přidáno: Některé funkce pro dekódování.

File:

• ProtocolBuffers/UProtocolBuffers.pas (modified) (7 diffs)

ProtocolBuffers/UProtocolBuffers.pas

@@ -18 +18 @@
 
   { TPBItem }
-
   TPBItem = class
     Name: string;
@@ -24 +23 @@
     ItemType: TPBItemType;
     ItemMode: TPBItemMode;
+    procedure SaveVariantToStream(Stream: TStream; Value: Integer);
     procedure SaveToStream(Stream: TStream); virtual;
-  end;
-
-  TPBMessage = class;
-
+    procedure LoadFromStream(Stream: TStream); virtual;
+    function LoadVariantFromStream(Stream: TStream);
+  end;
+
+  TPBMessageItem = class;
+
+  { TPBStringItem }
   TPBStringItem = class(TPBItem)
     Value: string;
   end;
 
+  { TPBIntegerItem }
   TPBIntegerItem = class(TPBItem)
     Value: Integer;
-  end;
-
+    procedure SaveToStream(Stream: TStream); override;
+    constructor Create;
+  end;
+
+  { TPBMessageItem }
   TPBMessageItem = class(TPBItem)
-    Tag: Integer;
-    Name: string;
-    ItemType: TPBItemType;
-  end;
-
-  { TPBMessage }
-
-  TPBMessage = class(TPBItem)
     Items: TList; // TList<TPBItem>;
     procedure SaveToStream(Stream: TStream); override;
+    procedure LoadFromStream(Stream: TStream); override;
     constructor Create;
+    destructor Destroy; override;
   end;
 
   { TProtocolBuffer }
-
   TProtocolBuffer = class
-    BaseMessage: TPBMessage;
+    BaseMessage: TPBMessageItem;
     procedure LoadFromStream(Stream: TStream);
     procedure SaveToStream(Stream: TStream);
+    constructor Create;
     destructor Destroy; override;
   end;
@@ -69 +70 @@
 procedure TProtocolBuffer.LoadFromStream(Stream: TStream);
 begin
-
+  BaseMessage.LoadFromStream(Stream);
 end;
 
@@ -75 +76 @@
 begin
   BaseMessage.SaveToStream(Stream);
+end;
+
+constructor TProtocolBuffer.Create;
+begin
+  BaseMessage := TPBMessageItem.Create;
 end;
 
@@ -83 +89 @@
 end;
 
-{ TPBMessage }
-
-procedure TPBMessage.SaveToStream(Stream: TStream);
+{ TPBMessageItem }
+
+procedure TPBMessageItem.SaveToStream(Stream: TStream);
+var
+  I: Integer;
 begin
   inherited SaveToStream(Stream);
-end;
-
-constructor TPBMessage.Create;
+  for I := 0 to Items.Count - 1 do
+    TPBItem(Items[I]).SaveToStream(Stream);
+end;
+
+procedure TPBMessageItem.LoadFromStream(Stream: TStream);
+begin
+  inherited LoadFromStream(Stream);
+end;
+
+constructor TPBMessageItem.Create;
 begin
   ItemType := itLengthDelimited;
+  Items := TList.Create;
+end;
+
+destructor TPBMessageItem.Destroy;
+var
+  I: Integer;
+begin
+  for I := 0 to Items.Count - 1 do
+    TPBItem(Items[I]).Free;
+  Items.Free;
+  inherited Destroy;
 end;
 
 { TPBItem }
 
-procedure TPBItem.SaveToStream(Stream: TStream);
+procedure TPBItem.SaveVariantToStream(Stream: TStream; Value: Integer);
 var
   ByteIndex: Byte;
@@ -103 +129 @@
 begin
   with TMemoryStreamEx(Stream) do begin
-    Data := ((Tag and $f) shl 3) or (Integer(ItemType) and $7);
-    ByteIndex := 0;
-    while Tag > (1 shl (ByteIndex * 8 + 4)) do begin
+    Data := Value and $7f;
+    ByteIndex := 1;
+    while Value > (1 shl (ByteIndex * 7)) do begin
       WriteByte(Data or $80);
-      Data := (Tag shr (ByteIndex * 8 + 4)) and $7f;
+      Data := (Value shr (ByteIndex * 7)) and $7f;
       Inc(ByteIndex);
     end;
@@ -114 +140 @@
 end;
 
+procedure TPBItem.SaveToStream(Stream: TStream);
+var
+  ByteIndex: Byte;
+  Data: Byte;
+begin
+  with TMemoryStreamEx(Stream) do begin
+    Data := ((Tag and $f) shl 3) or (Integer(ItemType) and $7);
+    ByteIndex := 0;
+    while Tag > (1 shl (ByteIndex * 7 + 4)) do begin
+      WriteByte(Data or $80);
+      Data := (Tag shr (ByteIndex * 7 + 4)) and $7f;
+      Inc(ByteIndex);
+    end;
+    WriteByte(Data);
+  end
+end;
+
+procedure TPBItem.LoadFromStream(Stream: TStream);
+var
+  Data: Byte;
+  ByteIndex: Byte;
+begin
+  Data := TMemoryStreamEx(Stream).ReadByte;
+  ItemType := TPBItemType(Data and 3);
+  Tag := (Data shr 3) and $f;
+  ByteIndex := 0;
+  while Data > $7f do begin
+    Data := TMemoryStreamEx(Stream).ReadByte;
+    Tag := Tag or ((Data and $7f) shl (ByteIndex * 7 + 4))
+    Inc(ByteIndex);
+  end;
+end;
+
+function TPBItem.LoadVariantFromStream(Stream: TStream);
+var
+  Data: Byte;
+  ByteIndex: Byte;
+begin
+  Data := TMemoryStreamEx(Stream).ReadByte;
+  Tag := Data and $7f;
+  ByteIndex := 1;
+  while Data > $7f do begin
+    Data := TMemoryStreamEx(Stream).ReadByte;
+    Tag := Tag or ((Data and $7f) shl (ByteIndex * 7))
+    Inc(ByteIndex);
+  end;
+end;
+
+{ TPBIntegerItem }
+
+procedure TPBIntegerItem.SaveToStream(Stream: TStream);
+begin
+  inherited SaveToStream(Stream);
+  SaveVariantToStream(Stream, Value);
+end;
+
+constructor TPBIntegerItem.Create;
+begin
+  ItemType := itVariant;
+end;
+
 end.