Merge pull request #74 from intersystems-community/master

fix-big-packages

Author: nsolov

Dockerfile

@@ -1,4 +1,4 @@
-FROM containers.intersystems.com/intersystems/iris-community:2022.2.0.270.0
+FROM containers.intersystems.com/intersystems/iris-community:2022.2.0.281.0
 
 WORKDIR /opt/registry
 

src/cls/ZPM/Package.cls

@@ -1,8 +1,10 @@
-Class ZPM.Package Extends (%Persistent, ZPM.JSON.Adaptor)
+Class ZPM.Package Extends (%Persistent, %JSON.Adaptor)
 {
 
 Parameter EXTENTQUERYSPEC = "name,version";
 
+Parameter %JSONIGNOREINVALIDFIELD As BOOLEAN = 1;
+
 Property name As %String(MAXLEN = 50) [ Required ];
 
 Index Name On name;
@@ -29,7 +31,7 @@ Index Repository On repository;
 
 Property dependencies As array Of %String;
 
-Property package As %Stream.GlobalBinary(%JSONINCLUDE = "INPUTONLY");
+Property package As %Stream.GlobalBinary(%JSONINCLUDE = "NONE");
 
 Property size As %Integer(%JSONINCLUDE = "OUTPUTONLY");
 
@@ -74,6 +76,17 @@ Method sizeGet() As %Integer
   return ..package.Size
 }
 
+Method packageFromBase64(base64 As %Stream.DynamicBinary) As %Status
+{
+  set sc = $$$OK
+  Set ..package = ##class(%Stream.GlobalBinary).%New()
+  while 'base64.AtEnd {
+    Set tSC = ..package.Write($system.Encryption.Base64Decode(base64.Read(43540, .sc))) 
+    Set:$$$ISERR(tSC) sc = $$$ADDSC(sc,tSC)
+  }
+  Quit sc
+}
+
 ClassMethod GetPackageHash(pStream As %Stream.Object) As %String
 {
   If (pStream="") { Return "" }

src/cls/ZPM/Registry.cls

@@ -186,6 +186,7 @@ ClassMethod PublishPackage() As %Status
 
   set package = ##class(ZPM.Package).%New() 
   $$$ThrowOnError(package.%JSONImport(%request.Content))
+  $$$ThrowOnError(package.packageFromBase64(%request.Content.%Get("package",,"stream")))
   $$$ThrowOnError(package.UpdateDescriptionFromManifest())
   do ##class(ZPM.Package).DeleteExistingPackages(package.name, package.version)
   $$$ThrowOnError(package.%Save())