Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[BZ-1063255] store generated classes in kproject jar when building it…
… with the kie-maven-plugin
- Loading branch information
1 parent
c3094c2
commit c572148
Showing
7 changed files
with
237 additions
and
123 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
136 changes: 136 additions & 0 deletions
136
drools-compiler/src/main/java/org/drools/compiler/kie/builder/impl/KieMetaInfoBuilder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,136 @@ | ||
| package org.drools.compiler.kie.builder.impl; | ||
|
|
||
| import com.google.protobuf.ByteString; | ||
| import org.drools.compiler.builder.impl.KnowledgeBuilderImpl; | ||
| import org.drools.compiler.commons.jci.stores.ResourceStore; | ||
| import org.drools.compiler.compiler.PackageRegistry; | ||
| import org.drools.compiler.kproject.models.KieModuleModelImpl; | ||
| import org.drools.core.factmodel.ClassDefinition; | ||
| import org.drools.core.rule.JavaDialectRuntimeData; | ||
| import org.drools.core.rule.KieModuleMetaInfo; | ||
| import org.drools.core.rule.TypeDeclaration; | ||
| import org.drools.core.rule.TypeMetaInfo; | ||
| import org.kie.api.builder.model.KieModuleModel; | ||
| import org.kie.api.definition.KiePackage; | ||
| import org.kie.api.definition.rule.Rule; | ||
| import org.kie.api.definition.type.FactType; | ||
|
|
||
| import java.io.ByteArrayOutputStream; | ||
| import java.io.IOException; | ||
| import java.util.ArrayList; | ||
| import java.util.HashMap; | ||
| import java.util.HashSet; | ||
| import java.util.List; | ||
| import java.util.Map; | ||
| import java.util.Set; | ||
|
|
||
| public class KieMetaInfoBuilder { | ||
|
|
||
| private final ResourceStore trgMfs; | ||
| private final InternalKieModule kModule; | ||
|
|
||
| public KieMetaInfoBuilder(ResourceStore trgMfs, InternalKieModule kModule) { | ||
| this.trgMfs = trgMfs; | ||
| this.kModule = kModule; | ||
| } | ||
|
|
||
| public void writeKieModuleMetaInfo() { | ||
| KieModuleMetaInfo info = generateKieModuleMetaInfo(); | ||
| trgMfs.write( KieModuleModelImpl.KMODULE_INFO_JAR_PATH, | ||
| info.marshallMetaInfos().getBytes(), | ||
| true ); | ||
| } | ||
|
|
||
| private KieModuleMetaInfo generateKieModuleMetaInfo() { | ||
| // TODO: I think this method is wrong because it is only inspecting packages that are included | ||
| // in at least one kbase, but I believe it should inspect all packages, even if not included in | ||
| // any kbase, as they could be included in the future | ||
| Map<String, TypeMetaInfo> typeInfos = new HashMap<String, TypeMetaInfo>(); | ||
| Map<String, Set<String>> rulesPerPackage = new HashMap<String, Set<String>>(); | ||
|
|
||
| KieModuleModel kieModuleModel = kModule.getKieModuleModel(); | ||
| for ( String kieBaseName : kieModuleModel.getKieBaseModels().keySet() ) { | ||
| KnowledgeBuilderImpl kBuilder = (KnowledgeBuilderImpl) kModule.getKnowledgeBuilderForKieBase( kieBaseName ); | ||
| Map<String, PackageRegistry> pkgRegistryMap = kBuilder.getPackageBuilder().getPackageRegistry(); | ||
|
|
||
| KieModuleCache.KModuleCache.Builder _kmoduleCacheBuilder = createCacheBuilder(); | ||
| KieModuleCache.CompilationData.Builder _compData = createCompilationData(); | ||
|
|
||
| for ( KiePackage kPkg : kBuilder.getKnowledgePackages() ) { | ||
| PackageRegistry pkgRegistry = pkgRegistryMap.get( kPkg.getName() ); | ||
| JavaDialectRuntimeData runtimeData = (JavaDialectRuntimeData) pkgRegistry.getDialectRuntimeRegistry().getDialectData( "java" ); | ||
|
|
||
| List<String> types = new ArrayList<String>(); | ||
| for ( FactType factType : kPkg.getFactTypes() ) { | ||
| Class< ? > typeClass = ((ClassDefinition) factType).getDefinedClass(); | ||
| TypeDeclaration typeDeclaration = pkgRegistry.getPackage().getTypeDeclaration( typeClass ); | ||
| if ( typeDeclaration != null ) { | ||
| typeInfos.put( typeClass.getName(), new TypeMetaInfo(typeDeclaration) ); | ||
| } | ||
|
|
||
| String className = factType.getName(); | ||
| String internalName = className.replace('.', '/') + ".class"; | ||
| byte[] bytes = runtimeData.getBytecode(internalName); | ||
| if (bytes != null) { | ||
| trgMfs.write( internalName, bytes, true ); | ||
| } | ||
| types.add( internalName ); | ||
| } | ||
|
|
||
| Set<String> rules = rulesPerPackage.get( kPkg.getName() ); | ||
| if( rules == null ) { | ||
| rules = new HashSet<String>(); | ||
| } | ||
| for ( Rule rule : kPkg.getRules() ) { | ||
| if( !rules.contains( rule.getName() ) ) { | ||
| rules.add(rule.getName()); | ||
| } | ||
| } | ||
| if (!rules.isEmpty()) { | ||
| rulesPerPackage.put(kPkg.getName(), rules); | ||
| } | ||
|
|
||
| addToCompilationData(_compData, runtimeData, types); | ||
| } | ||
|
|
||
| _kmoduleCacheBuilder.addCompilationData( _compData.build() ); | ||
| writeCompilationDataToTrg( _kmoduleCacheBuilder.build(), kieBaseName ); | ||
| } | ||
| return new KieModuleMetaInfo(typeInfos, rulesPerPackage); | ||
| } | ||
|
|
||
| private KieModuleCache.KModuleCache.Builder createCacheBuilder() { | ||
| return KieModuleCache.KModuleCache.newBuilder(); | ||
| } | ||
|
|
||
| private KieModuleCache.CompilationData.Builder createCompilationData() { | ||
| // Create compilation data cache | ||
| return KieModuleCache.CompilationData.newBuilder().setDialect("java"); | ||
| } | ||
|
|
||
| private void addToCompilationData(KieModuleCache.CompilationData.Builder _cdata, | ||
| JavaDialectRuntimeData runtimeData, | ||
| List<String> types) { | ||
| for ( Map.Entry<String, byte[]> entry : runtimeData.getStore().entrySet() ) { | ||
| if ( !types.contains( entry.getKey() ) ) { | ||
| KieModuleCache.CompDataEntry _entry = KieModuleCache.CompDataEntry.newBuilder() | ||
| .setId( entry.getKey() ) | ||
| .setData( ByteString.copyFrom(entry.getValue()) ) | ||
| .build(); | ||
| _cdata.addEntry( _entry ); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private void writeCompilationDataToTrg(KieModuleCache.KModuleCache _kmoduleCache, | ||
| String kieBaseName) { | ||
| try { | ||
| ByteArrayOutputStream out = new ByteArrayOutputStream(); | ||
| KieModuleCacheHelper.writeToStreamWithHeader( out, _kmoduleCache ); | ||
| String compilatonDataPath = "META-INF/" + kieBaseName.replace( '.', '/' ) + "/kbase.cache"; | ||
| trgMfs.write( compilatonDataPath, out.toByteArray(), true ); | ||
| } catch ( IOException e ) { | ||
| // what to do here? | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.