/*

* 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

*

* 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 javaobject;

import java.util.HashMap;

import java.util.Properties;

import PdxTests.PdxTypes1;

import PdxTests.PdxTypes10;

import PdxTests.PdxTypes2;

import PdxTests.PdxTypes3;

import PdxTests.PdxTypes4;

import PdxTests.PdxTypes5;

import PdxTests.PdxTypes6;

import PdxTests.PdxTypes7;

import PdxTests.PdxTypes8;

import PdxTests.PdxTypes9;

import org.apache.geode.cache.Cache;

import org.apache.geode.cache.CacheFactory;

import org.apache.geode.cache.Declarable;

import org.apache.geode.cache.Region;

import org.apache.geode.cache.execute.FunctionAdapter;

import org.apache.geode.cache.execute.FunctionContext;

import org.apache.geode.cache.execute.RegionFunctionContext;

import org.apache.geode.internal.cache.GemFireCacheImpl;

import org.apache.geode.pdx.internal.EnumInfo;

import org.apache.geode.pdx.internal.PdxField;

import org.apache.geode.pdx.internal.PdxType;

import org.apache.geode.pdx.internal.TypeRegistry;

public class ComparePdxTypes extends FunctionAdapter implements Declarable{

static HashMap javaClassnameVsPdxTypes = new HashMap();

@Override

public void execute(FunctionContext context) {

RegionFunctionContext rfc = (RegionFunctionContext)context;

String op = (String)rfc.getArguments();

try

{

if(op.equals("saveAllJavaPdxTypes")) {

putAllPdxTypes();

saveAllJavaPdxTypes();

context.getResultSender().lastResult(true);

} else if(op.equals("compareDotNETPdxTypes")){

compareDotNETPdxTypes();

context.getResultSender().lastResult(true);

} else {

context.getResultSender().lastResult(false);

}

}catch(Exception ex) {

CacheFactory.getAnyInstance().getLoggerI18n().info(ex);

context.getResultSender().sendException(ex);

}

}

@Override

public String getId() {

// TODO Auto-generated method stub

return "ComparePdxTypes";

}

@Override

public void init(Properties props) {

}

private void putAllPdxTypes() {

Region r = CacheFactory.getAnyInstance().getRegion("DistRegionAck");

PdxTypes1 p1 = new PdxTypes1();

r.put(PdxTypes1.class.getName(), p1);

PdxTypes2 p2 = new PdxTypes2();

r.put(PdxTypes2.class.getName(), p2);

PdxTypes3 p3 = new PdxTypes3();

r.put(p3.getClass().getName(), p3);

PdxTypes4 p4 = new PdxTypes4();

r.put(p4.getClass().getName(), p4);

PdxTypes5 p5 = new PdxTypes5();

r.put(p5.getClass().getName(), p5);

PdxTypes6 p6 = new PdxTypes6();

r.put(p6.getClass().getName(), p6);

PdxTypes7 p7 = new PdxTypes7();

r.put(p7.getClass().getName(), p7);

PdxTypes8 p8 = new PdxTypes8();

r.put(p8.getClass().getName(), p8);

PdxTypes9 p9 = new PdxTypes9();

r.put(p9.getClass().getName(), p9);

PdxTypes10 p10 = new PdxTypes10();

r.put(p10.getClass().getName(), p10);

}

private void getAllPdxTypes() {

Region r = CacheFactory.getAnyInstance().getRegion("DistRegionAck");

PdxTypes1 p1 = new PdxTypes1();

r.get(PdxTypes1.class.getName());

PdxTypes2 p2 = new PdxTypes2();

r.get(PdxTypes2.class.getName(), p2);

PdxTypes3 p3 = new PdxTypes3();

r.get(p3.getClass().getName(), p3);

PdxTypes4 p4 = new PdxTypes4();

r.put(p4.getClass().getName(), p4);

PdxTypes5 p5 = new PdxTypes5();

r.put(p5.getClass().getName(), p5);

PdxTypes6 p6 = new PdxTypes6();

r.put(p6.getClass().getName(), p6);

PdxTypes7 p7 = new PdxTypes7();

r.put(p7.getClass().getName(), p7);

PdxTypes8 p8 = new PdxTypes8();

r.put(p8.getClass().getName(), p8);

PdxTypes9 p9 = new PdxTypes9();

r.put(p9.getClass().getName(), p9);

PdxTypes10 p10 = new PdxTypes10();

r.put(p10.getClass().getName(), p10);

}

private void saveAllJavaPdxTypes() {

Region r = CacheFactory.getAnyInstance().getRegion("PdxTypes");

for(Object k : r.keySet()) {

Object obj =r.get(k);

if(obj instanceof EnumInfo) {

EnumInfo ei = (EnumInfo)obj;

javaClassnameVsPdxTypes.put(ei.toString().substring(5), ei);

}else {

PdxType pt = (PdxType)obj;

javaClassnameVsPdxTypes.put(pt.getClassName(), pt);

}

}

if(javaClassnameVsPdxTypes.size() != 11) {

throw new IllegalStateException("Java pdx types size are not equal to 11; and it is = " + javaClassnameVsPdxTypes.size());

}

}

private void compareDotNETPdxTypes() {

Region r = CacheFactory.getAnyInstance().getRegion("PdxTypes");

if(r.keySet().size() != 11) {

throw new IllegalStateException("compareDotNETPdxTypes Java pdx types should have PdxTypes enteries " + r.keySet().size());

}

for(Object k : r.keySet()) {

Object obj = r.get(k);

if(obj instanceof EnumInfo) {

EnumInfo ei = (EnumInfo)obj;

EnumInfo jei =(EnumInfo) javaClassnameVsPdxTypes.get(ei.toString().substring(5));

if(!ei.equals(jei)) {

throw new IllegalStateException("Pdxfield not matched DotNet:" + ei + " Java:" + jei);

}

continue;

}

PdxType dotNetPt = (PdxType)obj;

PdxType javaPt = (PdxType)javaClassnameVsPdxTypes.get(dotNetPt.getClassName());

if(dotNetPt.getFieldCount() != javaPt.getFieldCount()) {

}

for(PdxField dnPf : dotNetPt.getFields()) {

boolean matched = false;

for(PdxField jPf : javaPt.getFields()) {

if(dnPf.equals(jPf)) {

if(dnPf.getRelativeOffset() == jPf.getRelativeOffset()) {

if(dnPf.getVlfOffsetIndex() == jPf.getVlfOffsetIndex()) {

matched = true;

}

}

if(!matched) {

throw new IllegalStateException("Pdxfield not matched DotNet:" + dnPf + " Java:" + jPf);

}

break;

}

}

if(!matched) {

throw new IllegalStateException("Pdxfield not matched DotNet:" + dnPf );

}

}

}

}

}