@rxdi/cache

@StrongTyped @EasyAPI Created on Angular@2+

@Cache layer with capability to write in LocalStorage

More detailed documentation you can find here

For questions/issues you can write ticket here

Animation explanation:

Installation and basic examples:

To install this library, run:

$ npm install @rxdi/cache --save

Consuming @rxdi/cache

Import CacheModule.forRoot() in your Angular AppModule:

import {BrowserModule} from '@angular/platform-browser';
import {NgModule} from '@angular/core';
import {AppComponent} from './app.component';

// Import @rxdi/cache library
import {CacheModule} from '@rxdi/cache';

@NgModule({
  declarations: [
    AppComponent
  ],
  imports: [
    BrowserModule,
    // Import CacheModule optional parameters provided at the bottom of readme
    CacheModule.forRoot(),
    LibraryModule
  ],
  providers: [],
  bootstrap: [AppComponent]
})
export class AppModule { }

Once you import the library you need to inject CacheService inside your component, provider etc. and create cache Layer

***NOTE Every cache created by cacheService is treated like a LAYER , so you need to specify layer name like example above

import {Component, OnInit} from '@angular/core';
import {BehaviorSubject, Subscription} from 'rxjs';
import {CacheService, CacheLayer, CacheLayerItem} from '@rxdi/cache';

export interface Item {
  name: string;
}

export const EXAMPLE_CACHE_LAYER_NAME = 'example-layer';

@Component({
  selector: 'app-example',
  templateUrl: './example.component.html',
  styleUrls: ['./example.component.scss']
})
export class ExampleComponent implements OnInit {

  exampleLayer: CacheLayer<CacheLayerItem<Item>>;
  exampleLayerItems: BehaviorSubject<CacheLayerItem<Item>[]>;
  subscription: Subscription;

  constructor(
    private cacheService: CacheService
  ) {}

  ngOnInit() {
    // Here we define our cache layer name, this method returns instance of class CacheLayer<CacheLayerItem<Item>>
    this.exampleLayer = this.cacheService.create<Item>({
      name: EXAMPLE_CACHE_LAYER_NAME
    });

    // inside this.exampleCache you can find object named items returns BehaviorSubject<CacheLayerItem<Item>[]> object type
    this.exampleLayerItems = this.exampleLayer.items

    // Correct implementation of subscribing to collection of layer items and work inside component with it:
    // Recommended way to work with cacheLayer collection items is to create another observable asObservable and use items this way
    // Anyway it is better to let angular view model to handle subscription itself ( cartItems | async)
    // To work with collection this way you can use collection Instance returned from get above (this.cacheLayer) (Examples Below)

    this.subscription = this.exampleLayerItems.asObservable()
      .subscribe(items => {

      });

    // If you try to unsubscribe from this.cacheItems when you leave component state ngOnDestroy(),
    // you will loose observable stream from the cache layer and the result will be error ***Check NOTES below***
    // Another method is to take values single time only per component initialization

    this.exampleLayerItems
      .pipe(
        take(1)
      )
      .subscribe(itemCollection => itemCollection
        .forEach(item => {
          // Because we define interface for this items we have the following autosuggestion from the IDE
          const itemName = item.data.name;
        })
      );

    // Put item to current cache defined above
    // When there is a new item added to collection cache automatically emits new results to this.exampleLayerItems BehaviorSubject object type

    this.createItem({
      key:'example-key',
      data:{
        name:'pesho'
      }
    });

    // Get cached data from added item above will return {data:{ name:'pesho' }}
    const exampleData = this.get('example-key');

    // Remove item from current layer
    this.remove('example-key');

  }

  createItem(data: any) {
    this.exampleLayer.put(data);
  }

  get(key: string) {
    this.exampleLayer.get(key);
  }

  remove(key: string) {
    this.exampleLayer.remove(key);
  }

}

Get our new created cache from component which is somewhere inside our application

import {Injectable} from '@angular/core';
import {CacheService, CacheLayer} from '@rxdi/cache';
import {EXAMPLE_CACHE_LAYER_NAME, Item} from './example.provider';

@Injectable()
export class YourClass {
    cacheLayer: CacheLayer<CacheLayerItem<Item>>;
    constructor(private:cacheService:CacheService){
      this.cacheLayer = cacheService.get<Item>(EXAMPLE_CACHE_LAYER_NAME);
      // Now work with this collection the same as example above;
    }
}

Remove cache layer we created from other service or component.

import {Injectable} from '@angular/core';
import {CacheService} from '@rxdi/cache';
import {EXAMPLE_CACHE_LAYER_NzAME} from './example.provider';

@Injectable()
export class YourClass {
    constructor(private:cacheService:CacheService) {
      cacheService.remove(EXAMPLE_CACHE_LAYER_NAME);
    }
}

COMPLETE ADD TO CARD EXAMPLE:

Create CartProvider which will help us to reduce logic inside component

IMPORTANT When you use provider and define custom settings you need to use provider cache layer instance!

If you use CacheService.get() with the same cache name it may lead to not initialize current defined config when we create with specific config not global

Without provider you can use it as usual with get() and create() it will be safe but it will take Global Configuration instead.

import {Injectable} from "@angular/core";
import {CacheService, CacheLayer, CacheLayerItem, CacheServiceConfigInterface} from "@rxdi/cache";
import {Product} from "../core/config/queries/product/product.interface";

export const CART_CACHE_LAYER_NAME = 'cart';

export interface Product {
  id: string;
  name: string;
  title: string;
  price: string;
  quantity: number;
  completed: boolean;
  categoryId: number;
}

@Injectable()
export class CartProvider {

  cacheLayer: CacheLayer<CacheLayerItem<Product>>;
  items: BehaviorSubject<CacheLayerItem<Product>[]>;

  constructor(private cacheService: CacheService) {
    this.cacheLayer = this.cacheService.create<Product>(<CacheLayerInterface>{
      name: CART_CACHE_LAYER_NAME,
      config: <CacheServiceConfigInterface>{
        localStorage: true,
        maxAge: 10000,
        cacheFlushInterval: 10000
      }
    });
    this.items = this.cacheLayer.items;
  }

  putToCart(product: Product) {
    this.cacheLayer.put({
      key:product.id,
      data: product
    });
  }

  removeFromCart(product: Product) {
    this.cacheLayer.remove(product.id);
  }

}

Now lets define our component and inject CartProvider

import {Component, OnInit} from '@angular/core';

@Component({
  selector: 'app-cart',
  templateUrl: './cart.component.html',
  styleUrls: ['./cart.component.scss']
})
export class CartComponent implements OnInit {

  cartItems: BehaviorSubject<CacheLayerItem<Product>[]>;
  cacheLayer: CacheLayer<CacheLayerItem<Product>>;

  constructor(private cartProvider: CartProvider) {}

  ngOnInit() {}

  remove(product: Product) {
    this.cartProvider.removeFromCard(product)
  }

  updateItem(product: Product) {
    this.cartProvider.putToCart(product);
  }

}

How to consume items inside html

<div *ngFor="let product of (cartProvider.items | async)">
	{{item.key}} // is cache identity
    {{item.data.id}} // Cached data from current item from card layer Observable
    <-- removeKey in my case item.id is unique so i should remove item id -->
    <button (click)="remove(product)">Remove item</button>
</div>

How to define GlobalConfiguration

import {BrowserModule} from '@angular/platform-browser';
import {NgModule} from '@angular/core';
import {AppComponent} from './app.component';

// Import rxdi/cache
import {CacheModule, CacheConfigInterface} from '@rxdi/cache';

// Define global configuration
// You can set localStorage to true it will cache every layers like a localStorage item
// By default localStorage is set to false
export const CACHE_DI_CONFIG = <CacheConfigInterface>{
    localStorage: true,
    maxAge: 15 * 60 * 1000, // Items added to this cache expire after 15 minutes
    cacheFlushInterval: 60 * 60 * 1000, // This cache will clear itself every hour
}

@NgModule({
  declarations: [
    AppComponent
  ],
  imports: [
    BrowserModule,
    // Import CacheModule with CACHE_DI_CONFIG;
    CacheModule.forRoot(CACHE_DI_CONFIG)
  ],
  providers: [],
  bootstrap: [AppComponent]
})
export class AppModule { }

Service methods

Create cache layer

CacheService.create<any>({name: 'layer-name', settings?: CacheLayerInterface})

Optional you can define custom settings for every layer that you create just insert CacheLayerInterface from rxdi/cache like example for global config above

Returns: Instance of CacheLayer class Optional: settings interface CacheLayerInterface

Get layer from cache

CacheService.get<any>('layer-name');

Returns: Instance of CacheLayer class

Remove layer from cache

CacheService.remove('layer-name');

Returns: void

CacheLayer.createCacheParams({key: 'endpoint-key', params: {exampleParam: 'test'}});

Create Cache with parameters static public method of CacheLayer Class

Usage: when you have api endpoints with custom parameters and you need to cache result returned from response

Complete cache for endpoint with 8 rows more code without it :)

const endpointCache = this.cacheService.get('endpoint-cache');

function getUserById(id: number) {
  return Observable.create(observer => {
    const ENDPOINT = `/user/${id}`;
    const PARAMS = {
      client_credentials: true,
    };
    const cacheAddress = CacheLayer.createCacheParams({ key: ENDPOINT, params: PARAMS });
    if (endpointCache.get(cacheAddress)) {
      return observer.next(endpointCache.get(cacheAddress));
    }
    // endpointCache.put method like get returns instance of cached item so we can safely return to the observer above
	this.http.post(ENDPOINT, PARAMS)
	.map(user =>
		observer.next(endpointCache.put({ key: cacheAddress, data: user.json() }))
	)
	.subscribe()
  });
}

Cache Layer Instance methods

const cache = CacheService.get<T>('layer-name');

Put item to cache

cache.put({ key:'example-key', data: { exampleData:'' } });

Get item from cache

cache.get('example-key');

Get item from cache as observable it will emit every value changed for that specific key

cache.asObservable('example-key');

Remove item from cache

cache.remove('example-key');

Get items as observable (will emit value in the moment when it is populated)

cache.items.asObservable();

Cache all data from the request. It uses native fetch inside browser and will cache particular request to collection

cache.fetch<T>('https://api.github.com/repos/rxdi/core/releases');

NOTES:

FIRST

To avoid memory leaks it is really important to subscribe ONLY ONCE when you initialize items from cache,

or use examples bellow to iterate over items from collection and correct unsubscribe from them.

The example below is correct implementation how it will work without any problems!

Inside html when you use ( cartItems | async ) async pipe the view handles this automatically.`

  ngOnInit() {
    this.cacheLayer = this.cache.get<Product>(CART_CACHE_LAYER_NAME);
    this.cartItems = this.cacheLayer.items;


	// CORRECT EXAMPLE(BestWay) you need to unsubscribe when you leave component!

	this.subscription = this.cartItems.asObservable()
	  .subscribe(items => {
		// Do something
	  });

	// ANOTHER CORRECT EXAMPLE (this method will subscribe only once and you cannot get new results if there are any new)
	this.cartItems.pipe(take(1)).subscribe(collection => {
	  // Do something with collection here and initialize only once inside component
	});

    // WRONG EXAMPLE
    this.cartItems.subscribe(collection => {
    // don't do anything with collection this way or you will lead subscribing many times to the same collection
    });
  }

  ngOnDestroy() {
    this.subscription.unsubscribe();
  }

SECOND

Don't call unsubscribe directly on collection because you will loose reactive binding to collection and you will lead to following error

If you subscribe once, like example above you will have no problems at all!

"object unsubscribed" name: "ObjectUnsubscribedError" ngDebugContext:DebugContext_ {view: {…}, nodeIndex: 27, nodeDef: {…}, elDef: {…}, elView: {…}}ngErrorLogger:ƒ ()stack:"ObjectUnsubscribedError: object unsubscribed

License

MIT © Kristian Tachev(Stradivario)