4 files changed, 19 insertions, 6 deletions

diff --git a/common/inspection.h b/common/inspection.h
index 7abcd1c..e0321bf 100644
--- a/common/inspection.h
+++ b/common/inspection.h
@@ -35,6 +35,7 @@ struct Inspection
         inspection.entityIdentifier = entity.identifier();
         inspection.property = property;
         inspection.expectedValue = expectedValue;
+        inspection.type = PropertyInspectionType;
         return inspection;
     }
 
@@ -44,18 +45,30 @@ struct Inspection
         inspection.resourceIdentifier = entity.resourceInstanceIdentifier();
         inspection.entityIdentifier = entity.identifier();
         inspection.expectedValue = exists;
+        inspection.type = ExistenceInspectionType;
+        return inspection;
+    }
+
+    static Inspection CacheIntegrityInspection(const Sink::ApplicationDomain::Entity &entity)
+    {
+        Inspection inspection;
+        inspection.resourceIdentifier = entity.resourceInstanceIdentifier();
+        inspection.entityIdentifier = entity.identifier();
+        inspection.type = CacheIntegrityInspectionType;
         return inspection;
     }
 
     enum Type
     {
         PropertyInspectionType,
-        ExistenceInspectionType
+        ExistenceInspectionType,
+        CacheIntegrityInspectionType
     };
     QByteArray resourceIdentifier;
     QByteArray entityIdentifier;
     QByteArray property;
     QVariant expectedValue;
+    int type;
 };
 }
 }
diff --git a/common/resourceaccess.cpp b/common/resourceaccess.cpp
index 6dcc898..3696a93 100644
--- a/common/resourceaccess.cpp
+++ b/common/resourceaccess.cpp
@@ -353,7 +353,7 @@ KAsync::Job<void> ResourceAccess::sendRevisionReplayedCommand(qint64 revision)
 }
 
 KAsync::Job<void>
-ResourceAccess::sendInspectionCommand(const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue)
+ResourceAccess::sendInspectionCommand(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue)
 {
     flatbuffers::FlatBufferBuilder fbb;
     auto id = fbb.CreateString(inspectionId.toStdString());
@@ -366,7 +366,7 @@ ResourceAccess::sendInspectionCommand(const QByteArray &inspectionId, const QByt
     s << expectedValue;
 
     auto expected = fbb.CreateString(array.toStdString());
-    auto location = Sink::Commands::CreateInspection(fbb, id, 0, entity, domain, prop, expected);
+    auto location = Sink::Commands::CreateInspection(fbb, id, inspectionType, entity, domain, prop, expected);
     Sink::Commands::FinishInspectionBuffer(fbb, location);
     open();
     return sendCommand(Sink::Commands::InspectionCommand, fbb);
diff --git a/common/resourceaccess.h b/common/resourceaccess.h
index b9eaacd..82aa4d3 100644
--- a/common/resourceaccess.h
+++ b/common/resourceaccess.h
@@ -67,7 +67,7 @@ public:
         return KAsync::null<void>();
     };
     virtual KAsync::Job<void>
-    sendInspectionCommand(const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue)
+    sendInspectionCommand(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue)
     {
         return KAsync::null<void>();
     };
@@ -103,7 +103,7 @@ public:
     KAsync::Job<void> sendDeleteCommand(const QByteArray &uid, qint64 revision, const QByteArray &resourceBufferType) Q_DECL_OVERRIDE;
     KAsync::Job<void> sendRevisionReplayedCommand(qint64 revision) Q_DECL_OVERRIDE;
     KAsync::Job<void>
-    sendInspectionCommand(const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue) Q_DECL_OVERRIDE;
+    sendInspectionCommand(int inspectionType,const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue) Q_DECL_OVERRIDE;
     /**
      * Tries to connect to server, and returns a connected socket on success.
      */
diff --git a/common/resourcecontrol.cpp b/common/resourcecontrol.cpp
index ac6ddba..2be9b32 100644
--- a/common/resourcecontrol.cpp
+++ b/common/resourcecontrol.cpp
@@ -99,7 +99,7 @@ KAsync::Job<void> ResourceControl::inspect(const Inspection &inspectionCommand)
     resourceAccess->open();
     auto notifier = QSharedPointer<Sink::Notifier>::create(resourceAccess);
     auto id = QUuid::createUuid().toByteArray();
-    return resourceAccess->sendInspectionCommand(id, ApplicationDomain::getTypeName<DomainType>(), inspectionCommand.entityIdentifier, inspectionCommand.property, inspectionCommand.expectedValue)
+    return resourceAccess->sendInspectionCommand(inspectionCommand.type, id, ApplicationDomain::getTypeName<DomainType>(), inspectionCommand.entityIdentifier, inspectionCommand.property, inspectionCommand.expectedValue)
         .template then<void>([resourceAccess, notifier, id, time](KAsync::Future<void> &future) {
             notifier->registerHandler([&future, id, time](const Notification &notification) {
                 if (notification.id == id) {